时序时空数据库TSDB

    与天工产品对接

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

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

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

    通过物接入设备型配置数据写入TSDB

    如果用户通过物接入设备型来进行设备管理和设备数据接入,可以通过物接入的控制台或设备型的API,将设备上传的数据配置写入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的频率发送,物可视的仪表盘中即能刷新看到数据。

    上一篇
    数据预处理
    下一篇
    多用户访问控制