一、设备下行

设备下行定义

设备下行即是给设备发送消息，指令等所有对设备变更的内容都可以由设备下行实现。

下图以kafka为例：外部系统给设备下发指令，通过kafka生产者，将下发给设备的内容，缓存到mq对列。

而MQTT服务中通过kafka消费者将mq队列中的消息进行消费，发送给对应的设备。

创建设备下行

1. 进入 MQTT Dashboard，并点击 集成 -> 转换配置，点击页面右上角的 创建

2. 进行转换参数配置

   • 名称,转换配置名称
   • 主题, 这里是MQTT主题，支持字段映射 ，我们这里填写 /${productId}/${clientId}/function/get $是占位符
   • QOS，下发指令的消息指令
   • 是否保留消息，MQTT的保留消息功能
   • kafka主题是根据MQTT主题自动生成，按照step2，这里对应的kafka主题是 function_get

3. 进入 MQTT Dashboard，并点击 集成 -> 设备下行，点击页面右上角的 创建

4. 选择 KAFKA-服务，配置参数

   • 转换器，选择上面创建的转换器

     

   • 转换配置，选择step2中创建的转换配置

     

设备下行可视化观测，可以查看下发情况