数据推送 TDengine

RHILEX 支持将采集到的数据推送到 TDengine 服务端。

实例

新建 TDengine 北向资源

tdengine

新建规则

在接入设备操作界面给设备配置脚本：

rule

编写脚本

Lua

  Actions = {
    function(args)
        local dataT, err = json:J2T(args)
        if (err ~= nil) then
            Throw(err)
            return true, args
        end
        for _, value in pairs(dataT) do
            local params = {}
            params[value['tag']] = value.value
            local json = json:T2J({
                id = time:TimeMs(),
                method = "thing.event.property.post",
                params = params
            })
            local err = data:ToTdengine("$UUID", json)
            if err ~= nil then
                Throw(err)
            end
        end
        return true, args
    end
  }

其中 UUID 参数是一开始建立的 TDengine 北向资源的 ID，可以在快捷选择模板里面创建。

测试服务

使用 Docker 启动 TDengine

docker run -d --name my-tdengine -p 6030-6040:6030-6040 -p 6030:6030/udp -p 6020:6020 taosdata/tdengine

脚本解析

使用到的核心函数：

json:J2T：将 JSON String 转为 Lua 的表
json:T2J：将 Lua 的表转转为 JSON String
data:ToTdengine：数据转发到 TDengine 所有用到的函数均可在：规则指南 (opens in a new tab) 找到详细资料。

数据推送到 MongoDB 数据推送到 RDS