完成设备创建后，需在物联网平台控制台为产品定义物模型，用于与电信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操作栏的查看。
    在设备详情页的物模型数据 > 运行状态下，查看到数据已转化为物联网平台物模型的数据格式。运行数据