一、消息生产

设备终端接入OneNET平台不同的产品套件,上传设备消息至OneNET平台;

开通消息队列MQ服务,创建消息队列MQ实例,添加topic和sub;

选择不同的 数据源 配置规则引擎和消息目的地,自定义 SQL规则 对消息数据进行过滤,将消息转发到消息队列MQ。

1、配置规则引擎

用户可以通过规则引擎将物联网套件中的消息转发至消息队列MQ中

(1)打开MQTT物联网套件,进入产品详情页面,在下图所示的位置添加规则

image-20220209180725388

(2)选择消息源为:设备数据点消息

image-20220209181112117

(3)消息目的地选择“消息队列MQ”,如图:

image-20220209181215242

2、生产设备消息

用户可以使用平台的模拟工具产生设备消息,找到下图所示的位置:

image-20220209181944186

点击发送数据

image-20220209182024136

二、客户端消费数据

在MQTT.fx客户端,可以查看到接收到的数据(从控制台发送的模拟数据)

image-20220209182135924

也可以通过Linux平台运行MQTTS协议产品设备来源源不断地产生模拟数据

image-20220209182359001

MQTT.fx客户端一直在接收数据:

image-20220209182425370

Logo

技术共进,成长同行——讯飞AI开发者社区

更多推荐