与天工产品对接
更新时间:2022-05-20
通过规则引擎将数据写入TSDB
对于物联网数据,大部分设备是通过百度智能云天工的物接入上传的数据。设备的数据可以直接通过MQTT等各种协议通过物接入将设备数据接入云端,如果您上传的数据是json格式,则可以通过规则引擎将数据写入TSDB。
规则引擎可以通过配置SQL的方式,将收到的数据过滤、变型,然后转发到TSDB。转发的方式请参考文档。
通过物接入写入TSDB的Demo演示
使用天工的『物接入-规则引擎-TSDB-物可视』快速搭建物联网应用场景视频教程:
1. 场景描述
盾构机以1s的频率上传盾构机的感知数据,数据收到之后,将数据存储到TSDB中。可视化直接拿到数据进行展示。
1.1 数据接入
-
物接入中创建相关配置项(设备-身份-策略-主题的配图)。
-
用MQTT.fx模拟设备将数据接入。
MQTT.fx客户端下载地址。
mqtt.fx配置连接,并成功连接。
-
用JAVA应用程序作为服务端接受数据的程序 demo工程下载地址,红框处填上用户在物接入中的配置地址。
-
使用MQTT.fx的客户端向已经配置好的topic(stateUp)发送数据,运行java程序,在java服务端收到mqtt.fx客户端发送的数据:
发送模拟数据:
{ "name" : "dungouji", "deviceID":"S003", "temperature" : 34, "humidity":23, "station":{ "lng":123.3, "lat":34 } }
1.2 数据云端转发
-
配置规则引擎的规则。
*, CURRENT_TIMETAMP as myts, 'myts' AS _TSDB_META_v3.ts, 'name' AS _TSDB_META_v3.metric, 'deviceID' AS _TSDB_META_v3.tags.tag1, 'station.lng' AS _TSDB_META_v3.tags.tag2, 'station.lat' AS _TSDB_META_v3.tags.tag3, 'temperature' AS _TSDB_META_v3.fields.field1, 'humidity' AS _TSDB_META_v3.fields.field2
-
通过MQTT.fx 发布消息到指定主题中(stateUp),数据就会通过该条规则的执行,写入到TSDB中。
1.3 数据可视化展示
-
物可视,创建数据表,数据来源就是刚才写入的TSDB。
-
物可视,创建仪表盘,选取上一步创建的数据表。
1.4 完整场景展示
描述:通过java程序模拟盾构机,以1s的频率发送数据,数据通过物接入-规则引擎-TSDB-物可视,物可视中可以看到刷新数据。
-
物可视中设置的仪表盘生成链接 ,并通过生成的链接打开仪表盘。
-
用java程序模拟盾构机生成数据,以1s的频率发送,物可视的仪表盘中即能刷新看到数据。