设计Data Collector接收管道

Data Collector接收管道以独立执行模式运行。您可以在Data Collector中设计并运行接收管道。

Data Collector接收管道从边缘发送目标端读取数据。Data Collector接收管道上根据需要对数据进行更复杂的处理,然后其将数据写入到最终目标端。

(可选)您还可以设计一个Data Collector接收管道,以监控正在处理的数据,然后将数据发送到在SDC Edge上运行的边缘接收管道。边缘接收管道对数据起作用以控制边缘设备。

Data Collector接收管道包括对应的源端从边缘发送管道的目标端来读取。例如,如果边缘发送管道写入CoAP Client目标端,则Data Collector接收管道将使用CoAP Server源读取数据。

您可以在Data Collector接收管道中使用以下源端:

  • Amazon S3
  • Azure IoT/Event Hub Consumer
  • CoAP Server
  • HTTP Server
  • Kafka Consumer or Kafka Multitopic Consumer
  • Kinesis Consumer
  • MQTT Subscriber
  • WebSocket Server

MQTT阶段需要使用中间MQTT代理。例如,边缘发送管道使用MQTT Publisher目标端写入MQTT代理。MQTT代理临时存储数据,直到Data Collector接收管道中的MQTT Subscriber源读取数据为止。

其余阶段可以直接相互通信。它们不需要中间存储位置。

Data Collector接收管道可以包括任何类型的处理器,目标端和执行器。