您可以使用规则引擎,将物联网平台数据转发到消息队列(RocketMQ)中存储。从而实现消息从设备、物联网平台、RocketMQ到应用服务器之间的全链路高可靠传输能力。
前提条件
- 已创建消息队列(RocketMQ)实例和用于接收数据的Topic。RocketMQ使用方法,请参见RocketMQ快速入门。
- 已创建数据转发规则和编写处理数据的SQL,请参见设置数据流转规则。
您可以使用规则引擎,将物联网平台数据转发到消息队列(RocketMQ)中存储。从而实现消息从设备、物联网平台、RocketMQ到应用服务器之间的全链路高可靠传输能力。
参数 | 说明 |
---|---|
选择操作 | 选择发送数据到消息队列(RocketMQ)中。 |
地域 | 选择RocketMQ所在地域。 |
实例 | 选择RocketMQ实例。
您可以单击创建实例,跳转到消息队列控制台,创建RocketMQ实例,请参见消息队列文档。 |
Topic | 选择用于接收物联网平台数据的RocketMQ Topic。
您可以单击创建Topic,跳转到消息队列控制台,创建RocketMQ Topic。 |
Tag | (可选)设置标签。
设置标签后,所有通过该操作流转到RocketMQ对应Topic里的消息都会携带该标签。您可以在RocketMQ消息消费端,通过标签进行消息过滤。 标签长度限制为128字节,可以输入常量或变量。变量格式为${key},代表SQL处理后的JSON数据中key对应的value值。 |
授权 | 授权物联网平台将数据写入RocketMQ。
如您还未创建相关角色,单击创建RAM角色,跳转到RAM控制台,创建角色和授权策略,请参见创建RAM角色。 |
向规则SQL中定义的Topic发布一条消息,然后到RocketMQ控制台,查看是否成功接收到消息。
在文档使用中是否遇到以下问题
更多建议
匿名提交