IOT KAFKA 消息推送

IOT为设备对接层的一个服务，支持将各种协议设备的数据采集起来，封装好消息后推送到kafka中。如需使用设备数据，获取设备状态，可以通过订阅下方topic。

设备上下线状态推送

主题

deviceStatus

消息格式

{
  "type": "offLine",
  "productKey": "wu92d38u9e4",
  "devName": "junlnagongxiangwenni"
}

type：offLine 离线 onLine 在线

设备指标数据推送

主题

middle_priority_post

消息格式

名称	描述
dataType	数据类型 index 指标 alarm 告警
date	平台发送消息的时间，ISO 8601格式
devName	设备名称
id	消息ID
params	设备的采集的指标数据或产生的告警数据，不同设备的指标都会不同，取决于产品的物模型配置。
paramsStructContainList	消息是否包含list，当一次采集或设备上报的数据包含多条消息就会使用list的方式
productKey	产品ID
remakeName	设备的备注名称
version	消息的版本号

{
  "dataType": "index",
  "date": "2022-09-16T08:23:47.461Z",
  "devName": "AA63201000000999",
  "id": "878880612",
  "method": "thing.modbus.property.post",
  "params": {
    "grossWeight": "0.0",
    "netWeight": "-2.4453690414891496E-185",
    "rackStatus": "16472",
    "deviceStatus": "0"
  },
  "paramsStructContainList": false,
  "productKey": "CP_5xr7v79qknw",
  "remakeName": "",
  "version": "1.0"
}

设备告警数据推送

主题

event_post_exchange

消息格式

与middle_priority_post一致，区别在于设备的事件、告警消息会推送到此topic中

其他自定义topic

IOT平台支持更丰富、定制化的topic。可将任意产品 / 设备的设备上报消息、生命周期变化、设备状态变化通知自由配置到指定topic中，具体使用方法在IOT使用文档，服务端订阅模块。

IOT KAFKA 消息推送

IOT KAFKA 消息推送#

设备上下线状态推送#

主题#

消息格式#

设备指标数据推送#

主题#

消息格式#

设备告警数据推送#

主题#

消息格式#

其他自定义topic#

IOT KAFKA 消息推送

设备上下线状态推送

主题

消息格式

设备指标数据推送

主题

消息格式

设备告警数据推送

主题

消息格式

其他自定义topic