数据推送 MQTT

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

实例

新建 MQTT 北向资源

mqtt

新建规则

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

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

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

⚠️

如果是 IOTHUB，需要注意其数据格式，比如腾讯云的属性上报格式：

{
    "method":"report",
    "clientToken":"123",
    "timestamp":1628646783,
    "params":{
        "power_switch":1,
        "color":1,
        "brightness":32
       }
}

测试服务

使用 Docker 启动 EMQX

docker run --name my-emqx -d -p 1883:1883 -p 8083:8083 -p 18083:18083 emqx/emqx

脚本解析

使用到的核心函数：

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

数据推送到 UDP 数据推送到 MongoDB