阿里云物联网平台物模型数据解析脚本

2024-07-06 19:54| 来源: 网络整理| 查看: 265

在一些物联网业务场景中，由于资源受限或配置较低，设备端不适合直接构造物模型的JSON数据结构体与物联网平台进行直接通信。这种情况下，可以将设备上报的原数据直接透传到物联网平台。物联网平台调用您提交的数据解析脚本，将设备上行数据解析为物联网平台定义的标准格式（Alink JSON），再进行业务处理。在这里插入图片描述

目前支持解析两类数据：

自定义Topic上行数据，即将设备通过自定义Topic上报给云端的自定义格式数据Payload解析为JSON格式。上、下行物模型Topic的数据，即将设备上报给云端的自定义格式物模型数据解析为Alink JSON格式，和将云端下发的Alink JSON格式数据解析为设备自定义的格式。

我们这里使用的是：物模型数据解析数据格式为透传/自定义的产品下的设备与云端进行物模型数据通信时，需要物联网平台调用您提交的数据解析脚本，将上、下行物模型数据分别解析为物联网平台定义的标准格式（Alink JSON）和设备的自定义数据格式。

物联网平台接收到来自设备的数据时，先运行解析脚本，将透传的数据转换成Alink JSON格式的数据，再进行业务处理；物联网平台下发数据给设备前，也会先通过脚本将数据转换为设备的自定义格式，再下发给设备。

数据解析流程图：在这里插入图片描述

设备上报透传格式的属性或事件（上行数据）全流程图：在这里插入图片描述

调用设备服务或设置属性（下行数据）全流程图：

在这里插入图片描述

好了，接下来我们进行产品以及设备的配置：

1. 产品配置参数说明产品名称自定义产品名称所属品类自定义品类节点类型直连设备数据格式透传/自定义连网协议蜂窝 (2G / 3G / 4G / 5G)

产品物模型定义设备物模型参数定义如下，这部分定义与自定义协议对应，非常重要在这里插入图片描述

2. 设备端接入物联网平台

设备采用物模型通信 Topic中的透传上行用于设备发布属性、事件和扩展信息的数据。在这里插入图片描述这里我是用的是将Modbus数据通过MQTT协议发送到云平台的模块，设备发送到物联网平台的为16进制数据格式如下(Modbus帧)：

0x010412003700132f014e1f2a081a02001800f40008965b

这里我用的是采用ModbusSlave软件模拟设备数据，然后模块去查询这个虚拟设备的数据，数据定义如下: 在这里插入图片描述

3. 数据解析脚本

本示例的数据解析脚本(javascript)如下：

/** * 将设备自定义topic数据转换为json格式数据, 设备上报数据到物联网平台时调用 * 入参：topic 字符串，设备上报消息的topic * 入参：rawData byte[]数组不能为空 * 出参：jsonObj JSON对象不能为空 */ function transformPayload(topic, rawData) { var jsonObj = {} return jsonObj; } var COMMAND_REPORT = 0x00; //属性上报 var COMMAND_SET = 0x01; //属性设置 var COMMAND_REPORT_REPLY = 0x02; //上报数据返回结果 var COMMAND_SET_REPLY = 0x03; //属性设置设备返回结果 var COMMAD_UNKOWN = 0xff; //未知的命令 var ALINK_PROP_REPORT_METHOD = 'thing.event.property.post'; //物联网平台Topic，设备上传属性数据到云端 var ALINK_PROP_SET_METHOD = 'thing.service.property.set'; //物联网平台Topic，云端下发属性控制指令到设备端 var ALINK_PROP_SET_REPLY_METHOD = 'thing.service.property.set'; //物联网平台Topic, 设备上报属性设置的结果到云端 /** * 将设备的自定义格式数据转换为Alink协议的数据，设备上报数据到物联网平台时调用 * 入参：rawData byte[]数组不能为空 * 出参：jsonObj Alink JSON对象不能为空 */ function rawDataToProtocol(bytes) { uint8Array = new Uint8Array(bytes.length); for(var i=0;i}; params['FuelTankLiquidLevel'] = dataView.getUint16(3);//下标为modbus数据帧字节索引 params['FuelBoxLiquidLevel'] = dataView.getUint16(5); params['TotalRuntime'] = dataView.getUint16(7); params['TotalPower'] = Math.floor(dataView.getUint16(9)*0.01*100)/100; params['TotalStartTime'] = dataView.getUint16(11); params['OutPower'] = Math.floor(dataView.getUint16(13)*0.1*10)/10; //将获取到的数据进行缩小10倍处理 params['OutCurrent'] = Math.floor(dataView.getUint16(15)*0.1*10)/10; params['OutVoltage'] = Math.floor(dataView.getUint16(17)*0.1*10)/10; params['RunningStatus']= dataView.getUint16(19); jsonMap['params'] = params; //ALink JSON格式 - params标准字段 return jsonMap; } /** * 将Alink协议的数据转换为设备能识别的格式数据，物联网平台给设备下发数据时调用 * 入参：jsonObj Alink JSON对象不能为空 * 出参：rawData byte[]数组不能为空 * */ function protocolToRawData(json) { var method = json['method']; var id = json['id']; var version = json['version']; var payloadArray = []; if (method == ALINK_PROP_SET_METHOD) // 属性设置 { var params = json['params']; var FuelTankLiquidLevel= params['FuelTankLiquidLevel']; var FuelBoxLiquidLevel= params['FuelBoxLiquidLevel']; var TotalRuntime= params['TotalRuntime']; var TotalPower= params['TotalPower']; var TotalRuntime= params['TotalStartTime']; var TotalPower= params['OutPower']; var TotalPower= params['OutCurrent']; var TotalPower= params['OutVoltage']; var TotalPower= params['RunningStatus']; //按照自定义协议格式拼接 rawData payloadArray = payloadArray.concat(buffer_uint8(COMMAND_SET)); // command字段 payloadArray = payloadArray.concat(buffer_int32(parseInt(id))); // ALink JSON格式 'id'，将Json格式id转为字符串 payloadArray = payloadArray.concat(buffer_int16(FuelTankLiquidLevel)); // 属性'FuelTankLiquidLevel'的值，要注意数据类型 payloadArray = payloadArray.concat(buffer_uint16(FuelBoxLiquidLevel)); payloadArray = payloadArray.concat(buffer_uint16(TotalRuntime)); payloadArray = payloadArray.concat(buffer_float32(TotalPower)); payloadArray = payloadArray.concat(buffer_uint16(TotalStartTime)); payloadArray = payloadArray.concat(buffer_uint16(OutPower)); payloadArray = payloadArray.concat(buffer_uint16(OutCurrent)); payloadArray = payloadArray.concat(buffer_uint16(OutVoltage)); payloadArray = payloadArray.concat(buffer_uint16(RunningStatus)); } else if (method == ALINK_PROP_REPORT_METHOD) { //设备上报数据返回结果 var code = json['code']; payloadArray = payloadArray.concat(buffer_uint8(COMMAND_REPORT_REPLY)); //command字段 payloadArray = payloadArray.concat(buffer_int32(parseInt(id))); // ALink JSON格式 'id' payloadArray = payloadArray.concat(buffer_uint8(code)); } else { //未知命令，对于有些命令不做处理 var code = json['code']; payloadArray = payloadArray.concat(buffer_uint8(COMMAD_UNKOWN)); //command字段 payloadArray = payloadArray.concat(buffer_int32(parseInt(id))); // ALink JSON格式 'id' payloadArray = payloadArray.concat(buffer_uint8(code)); } return payloadArray; } //以下是部分辅助函数 function buffer_uint8(value) { var uint8Array = new Uint8Array(1); var dv = new DataView(uint8Array.buffer, 0); dv.setUint8(0, value); return [].slice.call(uint8Array); } function buffer_int16(value) { var uint8Array = new Uint8Array(2); var dv = new DataView(uint8Array.buffer, 0); dv.setInt16(0, value); return [].slice.call(uint8Array); } function buffer_int32(value) { var uint8Array = new Uint8Array(4); var dv = new DataView(uint8Array.buffer, 0); dv.setInt32(0, value); return [].slice.call(uint8Array); } function buffer_float32(value) { var uint8Array = new Uint8Array(4); var dv = new DataView(uint8Array.buffer, 0); dv.setFloat32(0, value); return [].slice.call(uint8Array); } 4. 测试数据解析

数据解析结果

{ "method": "thing.event.property.post", "id": "4", "params": { "TotalPower": 199.99, "FuelTankLiquidLevel": 55, "OutVoltage": 24.4, "RunningStatus": 8, "OutPower": 665.8, "TotalRuntime": 12033, "OutCurrent": 2.4, "FuelBoxLiquidLevel": 19, "TotalStartTime": 10760 }, "version": "1.0" } 5.数据解析完成后效果

在这里插入图片描述

❀❀❀完结撒花❀❀❀

觉得有帮助的同学动动你的小手打个赏吧😄

【本文地址】

公司简介

联系我们