非官方标准MQTT协议设备接入

问题

mqtt设备/网关发送和订阅主题与平台不一致并无法修改，怎么接入ThingsPanel平台?
mqtt设备/网关json报文规范与平台规范不一致，怎么接入ThingsPanel平台?

使用MQTT主题报文转换器

可以同时解决主题和报文转换。它一个平台外部的转换器，实现了简单的broker，并在broker内部做了主题和报文转换，数据流转流程：设备-》MQTT主题报文转换器-》ThingsPanel的MQTT Broker服务-》ThingsPanel平台,具体功能查看代码的README。

仓库地址：https://github.com/ThingsPanel/mqtt-converter.git

视频讲解：https://www.bilibili.com/video/BV1Zh4y127Za/?spm_id_from=333.337.search-card.all.click&vd_source=3205f3f58f033fa90037cb65ee98074c

使用规则引擎转发设备数据

使用规则引擎转发设备数据的方式常用来解决第一种问题。

然后在规则引擎中新建一条接入规则
拖拽一个mqtt in节点，填写设备主题接入数据(这里不使用平台的mqtt服务，需自己搭建一个私有的mqtt服务做转换用，数据流转流程：设备-》私有MQTT Broker服务-》规则引擎-》ThingsPanel的MQTT Broker服务-》ThingsPanel平台)
再拖拽一个mqtt out节点，与mqtt in节点连线
在mqtt out配置中需要添加新的mqtt-broker节点，根据平台mqtt网关/设备接入规则填写主题和认证方式（AccessToken接入填写用户名,MQTTBasic认证填写用户名和密码）
平台到设备的通信参考以上步骤
除了以上节点，合理使用其他功能节点，也可以转换报文规范并对设备传输的值加工和处理

使用编辑参数页面的`数据处理脚本`功能

数据处理脚本功能可解决第二种问题。

创建设备后，点击编辑参数，在数据处理下拉框选择自定义协议
在弹出的自定义数据解析脚本对话框中输入上行解析脚本和下行解析脚本
保存后创建其他同类设备的时候可以直接选择解析脚本
数据处理脚本通常还可对设备传输的值做加工处理
具体细节可以参考下面提供给的解析案例

案例

网关设备平台规范报文：

{
    "TH180001": {
        "temp": 26.5,
        "hum": 45.5
    },
    "TH180002": {
        "temp": 26.5,
        "hum": 45.5
    }
}

非规范设备报文：

{
    "sensorDatas": {
        "TH180001": {
            "temp": 265,
            "hum": 455
        },
        "TH180002": {
            "temp": 265,
            "hum": 455
        }
    },
    "type": 2
}

以上行解析脚本为例：

分析发现设备发来的报文多了一层嵌套，并且数值都未做处理
创建网关设备，添加两个子设备。（注意子设备地址在编辑参数中填写，同一网关中不可重复，如下图）

首先编写代码

// 调试说明：按照node环境下的调试方式，将此文件放在某个文件夹下，然后在这个文件夹下执行 node ThingsPanelScriptTestDemo.js
function encodeInp(msg, topic){
    // 将设备自定义msg（自定义形式）数据转换为json形式数据, 设备上报数据到物联网平台时调用
    // 入参：topic string 设备上报消息的 topic
    // 入参：msg byte[] 数组 不能为空
    // 出参：string
    // 处理完后将对象转回字符串形式
    // 例，byte[]转string：var msgString = String.fromCharCode.apply(null, msg);
    // 例，string转jsonObj：msgJson = JSON.parse(msgString);
    // 例，jsonObj转string：msgString = JSON.stringify(msgJson);
    var msgString = String.fromCharCode.apply(null, msg)
    var jsonObj = JSON.parse(msgString);
    newObj = jsonObj.sensorDatas
    for(var key in newObj){
        for(var k in newObj[key]){
        newObj[key][k] = newObj[key][k]/10
    }
    }
    msg = JSON.stringify(newObj);
    return msg;
}
// 字符串转字节数组
const decodedMsg = new Uint8Array([...'{"sensorDatas":{"TH180001":{"temp":265,"hum":455},"TH180002":{"temp":26.5,"hum":45.5}},"type":2}'].map(c => c.charCodeAt(0)));
console.log(decodedMsg);
// 调试代码
const topic = "gateway/attributes";
const encodedMsg = encodeInp(decodedMsg, topic);
console.log(encodedMsg); // {"TH180001":{"temp":26.5,"hum":45.5},"TH180002":{"temp":2.65,"hum":4.55}}注意：控制台的输出结果一定不包含转义字符，否则平台无法解析

使用在线js调试工具,这里用的是：https://www.lddgo.net/code/runcode/javascript
调试好以后，将函数粘贴进脚本保存（脚本在网关的编辑参数中，如图）
下行脚本的编写也同上

问题​

使用MQTT主题报文转换器​

使用规则引擎转发设备数据​

使用编辑参数页面的数据处理脚本功能​

案例​

问题

使用MQTT主题报文转换器

使用规则引擎转发设备数据

使用编辑参数页面的`数据处理脚本`功能

案例