MQTT自定义透传_DTU毗连阿里云

阿里云物联网平台定义的尺度数据格式为Alink JSON。对于低配置且资源受限或者对网络流量有要求的设备，不适合直接构造JSON数据与物联网平台通信，可将原数据透传到物联网平台。物联网平台提供数据分析功能，可以根据您提交的脚本，将数据在设备自定义格式和JSON格式之间转换。

自定义透传适合的场景为采用便宜单片机、功能比较弱的DTU方案，这些DTU对json这种格式分析可能比较费劲。

一、新建产品

1.新建产品

我们选择“自定义品类”，节点范例为“直连设备”，最重要的是数据格式肯定要选择“透传/自定义”。

 2.添加功能

 3.编写分析脚本

 

1. var COMMAND_REPORT = 0x00;
2. var COMMAND_SET = 0x01;
3. var ALINK_PROP_REPORT_METHOD = 'thing.event.property.post'; //标准ALink JSON格式topic， 设备 上传属性数据到 云端
4. var ALINK_PROP_SET_METHOD = 'thing.service.property.set'; //标准ALink JSON格式topic， 云端 下发属性控制指令 到设备端
6. /**
7. * 将设备自定义topic数据转换为json格式数据, 设备上报数据到物联网平台时调用
8. * 入参：topic   string 设备上报消息的topic
9. * 入参：rawData byte[]数组 不能为空
10. * 出参：jsonObj JSON对象 不能为空
11. */
12. function transformPayload(topic, rawData) {
13.         var jsonObj = {};
14.         return jsonObj;
15. }   
17. /**
18. * 将设备的自定义格式数据转换为Alink协议的数据，设备上报数据到物联网平台时调用
19. * 入参：bytes byte[]数组 不能为空
20. * 出参：jsonMap Alink JSON对象 不能为空
21. */
22. function rawDataToProtocol(bytes) {
23.         var uint8Array = new Uint8Array(bytes.length);
24.         for (var i = 0; i < bytes.length; i++) {
25.                 uint8Array[i] = bytes[i] & 0xff;
26.         }
27.         var dataView = new DataView(uint8Array.buffer, 0);
28.         var jsonMap = new Object();
29.         var fHead = uint8Array[0];
30.         if (fHead == COMMAND_REPORT) {
31.                 jsonMap['method'] = ALINK_PROP_REPORT_METHOD;
32.                 jsonMap['version'] = '1.0';
33.                 jsonMap['id'] = '' + dataView.getInt32(1);
34.                 var params = {};
35.                 params['LightVolt'] = dataView.getInt32(5);
36.                 params['PowerSwitch'] = uint8Array[9];
37.                 jsonMap['params'] = params;
38.         }
39.         return jsonMap;
40. }
42. /**
43. *  将Alink协议的数据转换为设备能识别的格式数据，物联网平台给设备下发数据时调用
44. *  入参：json Alink JSON对象  不能为空
45. *  出参：payloadArray byte[]数组      不能为空
46. *
47. */
48. function protocolToRawData(json) {
49.         var method = json['method'];
50.         var id = json['id'];
51.         var version = json['version'];
52.         var payloadArray = [];
53.         if (method == ALINK_PROP_SET_METHOD)
54.         {
55.             var params = json['params'];
56.             var prop_int32 = params['LightVolt'];
57.             var prop_bool = params['PowerSwitch'];
58.             //按照自定义协议格式拼接 rawdata
59.             payloadArray = payloadArray.concat(buffer_uint8(COMMAND_SET));
60.             payloadArray = payloadArray.concat(buffer_int32(parseInt(id)));
61.             payloadArray = payloadArray.concat(buffer_int32(parseInt(prop_int32)));
62.             payloadArray = payloadArray.concat(buffer_uint8(prop_bool));
63.         }
64.         return payloadArray;
65.     }
67. //以下是部分辅助函数
68. function buffer_uint8(value) {
69.     var uint8Array = new Uint8Array(1);
70.     var dv = new DataView(uint8Array.buffer, 0);
71.     dv.setUint8(0, value);
72.     return [].slice.call(uint8Array);
73. }
74. function buffer_int16(value) {
75.     var uint8Array = new Uint8Array(2);
76.     var dv = new DataView(uint8Array.buffer, 0);
77.     dv.setInt16(0, value);
78.     return [].slice.call(uint8Array);
79. }
80. function buffer_int32(value) {
81.     var uint8Array = new Uint8Array(4);
82.     var dv = new DataView(uint8Array.buffer, 0);
83.     dv.setInt32(0, value);
84.     return [].slice.call(uint8Array);
85. }
86. function buffer_float32(value) {
87.     var uint8Array = new Uint8Array(4);
88.     var dv = new DataView(uint8Array.buffer, 0);
89.     dv.setFloat32(0, value);
90.     return [].slice.call(uint8Array);
91. }
93. // 以下为脚本模版，您可以基于以下模版进行脚本编写
95. /**
96. * 将设备自定义topic数据转换为json格式数据, 设备上报数据到物联网平台时调用
97. * 入参：topic   string 设备上报消息的topic
98. * 入参：rawData byte[]数组 不能为空
99. * 出参：jsonObj JSON对象 不能为空
100. */
101. /* function transformPayload(topic, rawData) {
102.     var jsonObj = {};
103.     return jsonObj;
104. } */
106. /**
107. * 将设备的自定义格式数据转换为Alink协议的数据，设备上报数据到物联网平台时调用
108. * 入参：rawData byte[]数组 不能为空
109. * 出参：jsonObj Alink JSON对象 不能为空
110. */
111. /* function rawDataToProtocol(rawData) {
112.     var jsonObj = {};
113.     return jsonObj;
114. } */
116. /**
117. *  将Alink协议的数据转换为设备能识别的格式数据，物联网平台给设备下发数据时调用
118. *  入参：jsonObj Alink JSON对象  不能为空
119. *  出参：rawData byte[]数组      不能为空
120. *
121. */
122. /* function protocolToRawData(jsonObj) {
123.     var rawdata = [];
124.     return rawdata;
125. }
126. */

复制代码

二、配置dtu

如下图所示记录好平台的如下几个毗连参数

ProductKey

DeviceName

DeviceSecret

mqttHostUrl

port

订阅Topic

发布Topic

  

我们要用到的topic为物模子通信Topic，打开产品详情，并选择Topic类列表-物模子通信Topic，我们须要的是下面红框内的这两个topic

 

配置DUT三要素及通信参数
按如下序次操作设置DTU，并将上面记录的通信参数对应填入。

 
三、测试上传

先发一个初始数据000320f2e30000000001（注意使用十六进制发送）

 阿里云状态变更

 上报一条新的000320f2e30000000500

 状态立即更新

 

四、测试下发

找到监控运维，在线调试，我们在属性调试内设置好属性数据然后点击“设置”下发一条指令

 

设备端收到的数据如下（注意：记得选择十六进制显示否则是乱码）

 本文参考自：dtu阿里云自定义透传 (openluat.com)

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。