一、操作步骤
1. 登录 物联网通信控制台,单击产品概况模块右上方的查看详情。默认进入菜单栏 产品列表 首页。
2. 进入产品列表页面,单击消息队列,查看配置的信息。
·消息队列 CMQ:参考规则引擎配置规则,修改成使用规则引擎中 数据转发到消息队列 TDMQ。
·消息队列 Ckafa:参考规则引擎配置规则,修改成使用规则引擎中 数据转发到消息队列 CKAFKA。
3. 由于配置消息队列功能 CMQ 和 Ckafa,和配置规则引擎转发,客户业务平台收到的数据格式不同,需客户参与如下修改点进行服务端程序修改。
4. 服务端验证成功后,删除消息队列功能中的配置信息。
二、修改点
由于使用消息队列功能转发和规则引擎功能转发,客户业务平台收到的数据格式不同,需按下面指引进行修改。
三、设备上报消息
·消息队列功能转发的数据格式:
{ MsgType: "Publish", Topic: topic, Seq: 等同上报的mid, PayloadLen: payload长度, Payload: payload内容, ProductId: 产品ID, DeviceName: 设备名,}
·规则引擎功能转发的数据格式,参考规则引擎中 转发到 CKAFKA。
修改点:由于两种方式转发客户业务平台接收到的数据中,MsgType 字段的取值不同,如果客户业务平台用到 MsgType 字段,需进行修改。
四、设备状态变化通知
·消息队列功能转发的数据格式:
{ MsgType: "StatusChange", Topic: topic, Seq: 等同上报的mid, PayloadLen: 0, Payload: "", ProductId: 产品ID, DeviceName: 设备名, Event: 设备在线状态,取值Online和Offline}
·规则引擎功能转发的数据格式,参考规则引擎中 转发到 CKAFKA。
修改点:
·MsgType 字段的取值不同,如果客户业务平台用到 MsgType 字段,需进行修改。
·设备在线状态取值不同,消息队列功能是从 Event 字段获取设备状态,但规则引擎功能需从 Payload 中获取设备状态,Payload 中的数据解析详见规则引擎中 转发到 CKAFKA。