数据解析任务中源节点的Topic数据格式为原始数据时,可以使用自定义脚本进行解析。物联网平台支持配置JavaScript(ECMAScript 5)、Python 2.7和PHP 7.2语言的脚本。本文介绍自定义Topic数据解析脚本模板和示例。
JavaScript脚本示例
脚本模板
/**
 * 将设备自定义Topic数据转换为JSON格式数据,设备上报数据到物联网平台时调用。
 * 入参:data,byte[]数组,不能为空。
 * 出参:jsonObj,对象,不能为空。
 */
function executeScript(data) {
    var jsonObj = {};
    return jsonObj;
}脚本示例
/*
  示例数据:
  自定义Topic:
     /user/update,上报数据。
  输入参数:
     data: 0x000000000100320100000000
  输出参数:
    {
        "prop_float": 0,
        "prop_int16": 50,
        "prop_bool": 1
    }
 */
function executeScript(data) {
    var uint8Array = new Uint8Array(data.length);
    for (var i = 0; i < data.length; i++) {
        uint8Array[i] = data[i] & 0xff;
    }
    var dataView = new DataView(uint8Array.buffer, 0);
    var jsonMap = {};
    jsonMap['prop_int16'] = dataView.getInt16(5);
    jsonMap['prop_bool'] = uint8Array[7];
    jsonMap['prop_float'] = dataView.getFloat32(8);
    return jsonMap;
}Python脚本示例
脚本模板
# 将设备自定义Topic数据转换为JSON格式数据,设备上报数据到物联网平台时调用。  
# 入参: data,列表,列表元素取值为int类型,不能为空。
# 出参: jsonObj,字典。    
def execute_script(data):
   jsonObj = {}
   return jsonObj脚本示例
# coding=UTF-8
#  示例数据:
#  自定义Topic:/user/update,上报数据。
#  输入参数:
#     data: 0x000000000100320100000000
#  输出参数:
#  {
#     "prop_float": 0,
#     "prop_int16": 50,
#     "prop_bool": 1
#   }
def execute_script(data):
    uint8Array = []
    for byteValue in data:
        uint8Array.append(byteValue & 0xff)
    jsonMap = {}
    jsonMap['prop_int16'] = bytes_to_int(uint8Array[5:7])
    jsonMap['prop_bool'] = bytes_to_int(uint8Array[7: 8])
    jsonMap['prop_float'] = bytes_to_int(uint8Array[8:])
    return jsonMap
# byte数组转换为整型。
def bytes_to_int(bytes):
    data = ['%02X' % i for i in bytes]
    return int(''.join(data), 16)PHP脚本示例
脚本模板
<?php
/**
 * 将设备自定义Topic数据转换为JSON格式数据,设备上报数据到物联网平台时调用。
 * 入参:$data,普通数组,数组元素为整数。
 * 出参:$jsonObj,关联数组,关联数组key取值为英文字符串不能是字符的数字如"10",不能为空。
 */
function executeScript($data)
{
    $jsonObj = array();
    return $jsonObj;
}重要 
请避免使用全局变量或者static变量,否则会造成执行结果不一致。
脚本中,处理数据采用补码的方式, [-128, 127]补码范围为[0, 255]。例如:-1对应的补码为255(10进制表示)。
自定义协议解析的函数(executeScript)的入参为整型数组,需要通过0xFF进行与操作,获取其对应的补码。返回结果为关联数组,要求key取值包含非数组字符(例如:数组key为“10”,PHP数组中会获取到整数10)。
PHP执行环境对于异常处理要求严格,例如:发生错误会直接抛出异常,后续代码不会执行。为保证代码的健壮性,对于异常需要捕获并进行处理。
脚本示例
<?php
/*
  示例数据
  自定义Topic:
     /user/update,上报数据。
  输入参数:
     data: 0x000000000100320100000000。
  输出参数:
  {
     "prop_float": 0,
     "prop_int16": 50,
     "prop_bool": 1
   }
 */
function executeScript($bytes)
{
    $data = array();
    $length = count($bytes);
    for ($i = 0; $i < $length; $i++) {
        $data[$i] = $bytes[$i] & 0xff;
    }
    $jsonMap = array();
    $jsonMap['prop_int16'] = getInt16($data, 5);
    $jsonMap['prop_bool'] = $data[7];
    return $jsonMap;
}
function getInt16($bytes, $index)
{
    $array = array($bytes[$index], $bytes[$index + 1]);
    return hexdec(byteArrayToHexString($array));
}
function byteArrayToHexString($data)
{
    $hexStr = '';
    for ($i = 0; $i < count($data); $i++) {
        $hexValue = dechex($data[$i]);
        $tempHexStr = strval($hexValue);
        if (strlen($tempHexStr) === 1) {
            $hexStr = $hexStr . '0' . $tempHexStr;
        } else {
            $hexStr = $hexStr . $tempHexStr;
        }
    }
    return $hexStr;
}
相关文档
选择脚本语言,完成自定义脚本编辑和调试。具体操作,请参见配置源节点。
该文章对您有帮助吗?