Skip to content

设备下行 ​

1. 设备下行定义 ​

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

下图以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中创建的转换配置

      创建设备下行页面截图

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

创建设备下行页面截图

蜂信物联 | fastbee.cn