数据推送 MongoDB

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

实例

新建 MongoDB 北向资源

mongodb

⚠️

当前仅支持单节点模式，不支持集群。

新建规则

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

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:ToMongo("$UUID", json)
            if err ~= nil then
                Throw(err)
            end
        end
        return true, args
    end
  }

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

测试服务

使用 Docker 启动 MongoDB

docker run --name my-mongodb -d -p 27017:27017 mongo

脚本解析

使用到的核心函数：

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

数据推送到 MQTT 数据推送到 TDengine