本文提供JavaScript语言的自定义Topic消息解析脚本模板和示例。
脚本模板
var SELF_DEFINE_TOPIC_UPDATE_FLAG = '/user/update' //自定义Topic:/user/update。
var SELF_DEFINE_TOPIC_ERROR_FLAG = '/user/update/error' //自定义Topic:/user/update/error。
/**
* 将设备自定义Topic消息数据转换为JSON格式数据,设备上报数据到物联网平台时调用。
* 入参:topic,字符串,设备上报消息的Topic。
* 入参:rawData,byte[]数组,不能为空。
* 出参:jsonObj,对象,不能为空。
*/
function transformPayload(topic, rawData) {
var jsonObj = {};
return jsonObj;
}
示例脚本
说明 以下示例脚本仅用于解析自定义Topic消息。如果产品的数据格式为透传/自定义,还需编写物模型消息解析脚本。物模型消息解析脚本编写指导,请参见提交物模型消息解析脚本。
有关透传/自定义说明,请参见创建产品。
var SELF_DEFINE_TOPIC_UPDATE_FLAG = '/user/update' //自定义Topic:/user/update。
var SELF_DEFINE_TOPIC_ERROR_FLAG = '/user/update/error' //自定义Topic:/user/update/error。
/*
示例数据:
自定义Topic:
/user/update,上报数据。
输入参数:
topic: /${productKey}/${deviceName}/user/update
bytes: 0x000000000100320100000000
输出参数:
{
"prop_float": 0,
"prop_int16": 50,
"prop_bool": 1,
"topic": "/${productKey}/${deviceName}/user/update"
}
*/
function transformPayload(topic, bytes) {
var uint8Array = new Uint8Array(bytes.length);
for (var i = 0; i < bytes.length; i++) {
uint8Array[i] = bytes[i] & 0xff;
}
var dataView = new DataView(uint8Array.buffer, 0);
var jsonMap = {};
if(topic.includes(SELF_DEFINE_TOPIC_ERROR_FLAG)) {
jsonMap['topic'] = topic;
jsonMap['errorCode'] = dataView.getInt8(0)
} else if (topic.includes(SELF_DEFINE_TOPIC_UPDATE_FLAG)) {
jsonMap['topic'] = topic;
jsonMap['prop_int16'] = dataView.getInt16(5);
jsonMap['prop_bool'] = uint8Array[7];
jsonMap['prop_float'] = dataView.getFloat32(8);
}
return jsonMap;
}