有奖捉虫:行业应用 & 管理与支持文档专题 HOT
文档中心 > 物联网通信 > 常见问题 > 消息队列如何迁移至规则引擎

操作背景

由于消息队列规则引擎,在功能上存在重叠,平台将下线消息队列功能,本文档用于指导存量用户从消息队列迁移到规则引擎。

操作步骤

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


http://www.vxiaotou.com