与天工产品对接

通过规则引擎将数据写入TSDB

对于物联网数据，大部分设备是通过百度智能云天工的物接入上传的数据。设备的数据可以直接通过MQTT等各种协议通过物接入将设备数据接入云端，如果您上传的数据是json格式，则可以通过规则引擎将数据写入TSDB。

规则引擎可以通过配置SQL的方式，将收到的数据过滤、变型，然后转发到TSDB。转发的方式请参考文档。

通过物接入写入TSDB的Demo演示

使用天工的『物接入-规则引擎-TSDB-物可视』快速搭建物联网应用场景视频教程：

1. 场景描述

盾构机以1s的频率上传盾构机的感知数据，数据收到之后，将数据存储到TSDB中。可视化直接拿到数据进行展示。

1.1 数据接入

1. 物接入中创建相关配置项(设备-身份-策略-主题的配图)。

   

2. 用MQTT.fx模拟设备将数据接入。

   MQTT.fx客户端下载地址。

   mqtt.fx配置连接，并成功连接。

   

   

3. 用JAVA应用程序作为服务端接受数据的程序 demo工程下载地址，红框处填上用户在物接入中的配置地址。

   

4. 使用MQTT.fx的客户端向已经配置好的topic(stateUp)发送数据，运行java程序，在java服务端收到mqtt.fx客户端发送的数据:

   发送模拟数据:

   {
   		"name" : "dungouji", 
   		"deviceID":"S003", 
   		"temperature" : 34, 
   		"humidity":23, 
   		"station":{ 
   		"lng":123.3,
   "lat":34
   } 
   
   } 

   

1.2 数据云端转发

1. 配置规则引擎的规则。

   *, 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

   

2. 通过MQTT.fx 发布消息到指定主题中(stateUp)，数据就会通过该条规则的执行，写入到TSDB中。

   

   

1.3 数据可视化展示

1. 物可视，创建数据表，数据来源就是刚才写入的TSDB。

   

2. 物可视，创建仪表盘，选取上一步创建的数据表。

   

1.4 完整场景展示

描述:通过java程序模拟盾构机，以1s的频率发送数据，数据通过物接入-规则引擎-TSDB-物可视，物可视中可以看到刷新数据。

1. 物可视中设置的仪表盘生成链接 ，并通过生成的链接打开仪表盘。

   

   

2. 用java程序模拟盾构机生成数据，以1s的频率发送，物可视的仪表盘中即能刷新看到数据。