Script de exemplo em PHP - IoT Platform: Central de Documentação do Alibaba Cloud

Este tópico fornece um modelo e um exemplo de script PHP para analisar dados enviados a tópicos personalizados.

Modelo de script

Use o seguinte modelo PHP para escrever um script de análise de dados:

<?php
/**
 * Convert the data that is sent by a device to a custom topic to JSON data when the device submits data to IoT Platform. 
 * $topic: the input parameter that specifies the topic to which the device sends messages. The value is a string. 
 * $rawData: the input parameter. The value is an array of integers. 
 * $jsonObj: an output parameter. The value is a JSON object that indicates an association array. The value of each key must be a string that is not a numeric string such as "10". Key values cannot be empty. 
 */
function transformPayload($topic, $rawData)
{
    $jsonObj = array();
    return $jsonObj;
}
?>

Observações sobre a escrita do script

Não use variáveis globais ou estáticas para evitar resultados inconsistentes.
Processe os dados no script com a operação de complemento de dois. O intervalo de complemento para valores entre [-128.127] é [0.255]. Por exemplo, o complemento de -1 é 255 em decimal.
O parâmetro de entrada da função transformPayload é um array de inteiros. Use 0xFF na operação AND bit a bit para obter o complemento. O resultado retornado é um array associativo. Cada valor de key deve conter caracteres não numéricos. Por exemplo, se um valor de key for "10", o array PHP recuperará o inteiro 10.
O ambiente de execução PHP é rigoroso no tratamento de exceções. Em caso de erro, o sistema lança uma exceção e interrompe a execução do código subsequente. Capture e trate as exceções para garantir a robustez do código.

Script de exemplo

Nota

O script de exemplo a seguir analisa apenas mensagens enviadas para tópicos personalizados. Se você definir o parâmetro

Data Type

do produto como

Custom

, escreva também um script para analisar mensagens da Thing Specification Language (TSL). Para mais informações, consulte

Enviar um script de análise de mensagem de modelo TSL

Para obter informações sobre custom data formats, consulte Criar um produto.

<?php
/*
  Sample data
  Use the following custom topic to submit data:
     /user/update. 
  Input:
     topic: /${productKey}/${deviceName}/user/update
     bytes: 0x000000000100320100000000 
  Output:
  {
     "prop_float": 0,
     "prop_int16": 50,
     "prop_bool": 1,
     "topic": "/${productKey}/${deviceName}/user/update"
   }
 */
function transformPayload($topic, $bytes)
{
    $data = array();
    $length = count($bytes);
    for ($i = 0; $i < $length; $i++) {
        $data[$i] = $bytes[$i] & 0xff;
    }

    $jsonMap = array();

    if (strpos($topic, '/user/update/error') !== false) {
        $jsonMap['topic'] = $topic;
        $jsonMap['errorCode'] = getInt8($data, 0);
    } else if (strpos($topic, '/user/update') !== false) {
        $jsonMap['topic'] = $topic;
        $jsonMap['prop_int16'] = getInt16($data, 5);
        $jsonMap['prop_bool'] = $data[7];
    }

    return $jsonMap;
}

function getInt32($bytes, $index)
{
    $array = array($bytes[$index], $bytes[$index + 1], $bytes[$index + 2], $bytes[$index + 3]);

    return hexdec(byteArrayToHexString($array));
}

function getInt16($bytes, $index)
{
    $array = array($bytes[$index], $bytes[$index + 1]);

    return hexdec(byteArrayToHexString($array));
}

function getInt8($bytes, $index)
{
    $array = array($bytes[$index]);
    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;
}

function hexStringToByteArray($hex)
{
    $result = array();
    $index = 0;
    for ($i = 0; $i < strlen($hex) - 1; $i += 2) {
        $result[$index++] = hexdec($hex[$i] . $hex[$i + 1]);
    }
    return $result;
}

function concat($array, $data)
{
    return array_merge($array, $data);
}

function toHex($data)
{
    $var = dechex($data);
    $length = strlen($var);
    if ($length % 2 == 1) {
        $var = '0' . $var;
    }
    return $var;
}