完成設備創建后，需在物聯網平臺控制臺為產品定義物模型，用于與電信AEP平臺進行通信。阿里云的物模型和中國電信平臺物模型的數據格式不同，需要在物聯網平臺中進行格式轉換。本案例通過Python腳本完成轉換。

操作步驟

  1. 回到物聯網平臺的尊享型實例下，單擊左側導航欄的設備管理 > 設備，單擊云網關設備（15008261001）的查看，單擊日志服務下的前往查看。
  2. 在云端運行日志頁簽的日志列表中，單擊查看，查看該設備到云的消息。
  3. 在內容下拉列表選擇Hex，復制并保存內容到本地，用于后續數據分析腳本驗證。
    HEX
  4. 在左側導航欄，選擇設備管理 > 產品，單擊產品NBProduct1，在產品詳情頁，單擊數據解析頁簽，選擇Python 2.7，刪除原腳本代碼，復制粘貼以下腳本代碼。
    本示例腳本僅適用當前案例，您可根據實際物模型，進行修改。具體操作，請參見提交物模型消息解析腳本。
    # -*- coding: UTF-8 -*-
# 以下為Alink產品模板，您可以基于以下模板進行腳本編寫

# 將設備自定義Topic數據轉換為JSON格式數據, 設備上報數據到物聯網平臺時調用
# 入參：topic   字符串，設備上報消息的Topic
# 入參：rawData 列表，列表元素取值為int類型    不能為空
# 出參：jsonObj 字典
def transform_payload(topic, rawData):
   jsonObj = {}
   return jsonObj

import json
import common_util

ALINK_PROP_REPORT_METHOD = 'thing.event.property.post'
COMMAND_REPORT = 0x00  # 屬性上報。
COMMAND_SET = 0x01  # 屬性設置。
COMMAND_REPORT_REPLY = 0x02  # 上報數據返回結果。
COMMAND_SET_REPLY = 0x03  # 屬性設置設備返回結果。
COMMAD_UNKOWN = 0xff  # 未知的命令。
ALINK_PROP_SET_METHOD = 'thing.service.property.set'  # 物聯網平臺Topic，云端下發屬性控制指令到設備端。
ALINK_PROP_SET_REPLY_METHOD = 'thing.service.property.set'  # 物聯網平臺Topic，設備上報屬性設置的結果到云端。
SELF_DEFINE_TOPIC_UPDATE_FLAG = '/user/update'  # 自定義Topic：/user/update。
SELF_DEFINE_TOPIC_ERROR_FLAG = '/user/update/error' # 自定義Topic：/user/update/error。

# 將設備的自定義格式數據轉換為Alink協議的數據，設備上報數據到物聯網平臺時調用
# 入參：rawData 列表，列表元素取值為int類型    不能為空
# 出參：jsonObj 字典                         不能為空
def raw_data_to_protocol(rawData):
    output = []
    for iters in rawData:
        output.append(chr(iters))

    inStr = ''.join(output)

    try:
        json_object = json.loads(inStr)
        # matched_out = json_object['notifyType']
        deviceId = json_object['deviceId']
        water_consumption = json_object['payload']
        running_data = water_consumption['water_consumption']
        # gatewayId = json_object['gatewayId']
        # service = json_object['service']
        # data_object = service['data']
        # imei = data_object['IMEI']
        # MeasureValue = json_object['MeasureValue']
        # Temperature = json_object['Temperature']
        # BatteryVoltage = data_object['BatteryVoltage']
    except ValueError, e:
        MeasureValue = 'err'
        # imei = 'err'

    jsonMap = {}
    jsonMap['method'] = ALINK_PROP_REPORT_METHOD
    jsonMap['version'] = '1.0'
    jsonMap['id'] = '123'
    params = {}
    # params['IMEI'] = imei
    params['deviceId'] = deviceId
    params['water_consumption']= running_data
    # params['gatewayId'] = gatewayId
    # params['MeasureValue'] = MeasureValue
    # params['BatteryVoltage'] = BatteryVoltage
    # params['Temperature'] = Temperature
    jsonMap['params'] = params
    return jsonMap

# 8位整型轉成byte數組。
def int_8_to_byte(value):
    t_value = '%02X' % value
    if len(t_value) % 2 != 0:
        t_value += '0'

    return hex_string_to_byte_array(t_value)

    # 32位整型轉成byte數組。
def int_32_to_byte(value):
    t_value = '%08X' % value
    if len(t_value) % 2 != 0:
        t_value += '0'

    return hex_string_to_byte_array(t_value)


# 16位整型轉成byte數組。
def int_16_to_byte(value):
    t_value = '%04X' % value
    if len(t_value) % 2 != 0:
        t_value += '0'

    return hex_string_to_byte_array(t_value)


# 16進制字符串轉成byte數組。
def hex_string_to_byte_array(str_value):
    if len(str_value) % 2 != 0:
        return None

    cycle = len(str_value) / 2

    pos = 0
    result = []
    for i in range(0, cycle, 1):
        temp_str_value = str_value[pos:pos + 2]
        temp_int_value = int(temp_str_value, base=16)

        result.append(temp_int_value)
        pos += 2
    return result


# 將Alink協議的數據轉換為設備能識別的格式數據，物聯網平臺給設備下發數據時調用
# 入參：jsonData 字典                                           不能為空
# 出參：rawdata  列表    列表元素取值為int類型且大小為[0, 255]之間  不能為空
def protocol_to_raw_data(myjson):
    payload_array = []
    in_params = myjson.get("params")
    test = in_params.get('test', None)
    method = myjson.get('method')
    print(method);

    if method == ALINK_PROP_SET_METHOD:
        params = myjson.get('params')

        params = {}
        params['test'] = test

        content= {}
        content['params']=params
        content['serviceIdentifier'] = 'test'

        mystr = json.dumps(content)

        for ch in mystr:
                print(ch)
                payload_array = payload_array + int_8_to_byte(ord(ch))

    elif method == ALINK_PROP_REPORT_METHOD:
        code = json.get('code', None)
        payload_array = payload_array + int_8_to_byte(COMMAND_REPORT_REPLY)
        payload_array = payload_array + int_32_to_byte(int(id))
        payload_array = payload_array + int_8_to_byte(code)
    else:
        code = json.get('code')
        payload_array = payload_array + int_8_to_byte(COMMAD_UNKOWN)
        payload_array = payload_array + int_32_to_byte(int(id))
        payload_array = payload_array + int_8_to_byte(code)

    return payload_array
  5. 在模擬輸入下，選擇模擬類型為設備上報數據，復制粘貼步驟3中的內容，單擊執行。
  6. 確認腳本可用后，單擊提交，提交腳本到物聯網平臺系統。
  7. 回到中國電信AEP平臺，在設備nbdevice的AEP-在線調試頁面，再上報一次用水量。
    電信上報數據
  8. 回到物聯網平臺的尊享型實例下，選擇設備管理 > 設備，單擊設備15008261001操作欄的查看。
    在設備詳情頁的物模型數據 > 運行狀態下，查看到數據已轉化為物聯網平臺物模型的數據格式。運行數據