物联网平台流转数据到服务器
数据流转流程图
设备上报数据至Iot Link,经由物模型解析成Yelink Json数据格式发送到Kafka消息队列中
流转到Kafka的数据格式
{
"productKey": "5i0nisvx1ns",
"devName": "feeder_1",
"id": "851547923",
"version": "1.0",
"method": "thing.modbus.property.post",
"params": {
"productionSpeed": 0.0,
"totalNumber": 1737.0,
"runningState": 1.0
}
}
参数 | 类型 | 说明 |
---|---|---|
productKey | String | 产品Id。 |
devName | String | 设备名称。 |
id | String | 消息ID号。String类型的数字,取值范围0~4294967295,且每个消息ID在当前设备中具有唯一性。 |
version | String | 协议版本号,目前协议版本号唯一取值为1.0。 |
method | String | 请求方法。取值:thing.event.property.post。 |
params | Object | 请求参数。如以上示例中,设备上报了的三个属性productionSpeed、totalNumber、runningState及其属性值。 |
流转到Kafka的Topic
- MQTT协议、TCP协议、Lora协议设备的Topic为设备的产品Id(productKey)
- Modbus协议设备的Topic为modbus_topic
- SqlServer设备的Topic由 模板设定的Topic决定,默认是设备的ProductKey