编写自定义脚本

数据解析任务中源节点的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;
}

相关文档

选择脚本语言,完成自定义脚本编辑和调试。具体操作,请参见配置源节点