【转】paho在OneNET平台的应用

熊掌五十块

使用python2.7测试通过，实现消息订阅，发布，平台数据下发，存储功能。
一定要修改下面代码
clientid = '8760549' # 创建设备时得到的设备ID，为数字字串
username = '79581' # 注册产品时，平台分配的产品ID，为数字字串
password = 'iDO9cRe85v2wpgFm2hQsMiapP=U=' # 为设备的鉴权信息（即唯一设备编号，SN），或者为apiKey，为字符串
安装 sudo pip install paho-mqtt
关于paho的使用参考：https://pypi.python.org/pypi/paho-mqtt/1.3.0

实现功能：
平台下发的数据，会转发给订阅了test主题的设备。收到主题为upload后，会将数据类型3:Json数据2的固定数据{"a":1,"c":3,"b":2,"d":4}发给平台。
树莓派上也同样适用。

不知道有没有EDP的python库可以用，没有的话，我打算自己弄一个，后面在树莓派上用。||ヽ(*￣▽￣*)ノミ|Ю


原帖链接：https://open.iot.10086.cn/bbs/thread-16116-1-1.html

• #!/usr/bin/python
• # -*- coding:utf-8 -*-
• import paho.mqtt.client as mqtt
• try:
•     import paho.mqtt.publish as publish
• except ImportError:
•     # This part is only required to run the example from within the examples
•     # directory when the module itself is not installed.
•     #
•     # If you have the module installed, just use "import paho.mqtt.publish"
•     import os
•     import inspect
•     cmd_subfolder = os.path.realpath(
•         os.path.abspath(os.path.join(os.path.split(inspect.getfile(inspect.currentframe()))[0], "../src")))
•     if cmd_subfolder not in sys.path:
•         sys.path.insert(0, cmd_subfolder)
•     import paho.mqtt.publish as publish
• hostname = '183.230.40.39'  # OneNET服务器地址
• port = 6002  # OneNET服务器端口地址
• clientid = '8760549'  # 创建设备时得到的设备ID，为数字字串
• username = '79581'  # 注册产品时，平台分配的产品ID，为数字字串
• password = 'iDO9cRe85v2wpgFm2hQsMiapP=U='  # 为设备的鉴权信息（即唯一设备编号，SN），或者为apiKey，为字符串
• topic1 = '$creq/#' #订阅平台下发命令主题
• topic2 = 'upload'
• # 连接成功回调函数
• def on_connect(client, userdata, flags, rc):
•     print('Connected with result code ' + str(rc))
•     # Subscribing in on_connect() means that if we lose the connection and
•     # reconnect then subscriptions will be renewed.
•     # 连接完成之后订阅gpio主题
•     client.subscribe(topic1, 0) # 参数一为topic字符串， 参数二为QoS级别，默认QoS=0
•     client.subscribe(topic2)
• # 消息推送回调函数
• def on_message(client, userdata, msg):
•     print('[topic:]'+msg.topic + '  ' + '[payload:]'+str(msg.payload))
•     if msg.topic == 'upload': # 如果收到upload主题，就将数据类型3（json数据2）内容上传给OneNET平台
•         dp_load = '{"a":1,"c":3,"b":2,"d":4}'
•         dp_type = 3
•         dp_len = len(dp_load)
•         dp=bytearray()
•         dp.append(dp_type)
•         dp.append((dp_len >> 8) & 0xFF)
•         dp.append(dp_len & 0xFF)
•         dp = dp + dp_load
•         print repr(dp)
•         (rc, final_mid) = client.publish('$dp', str(dp), 2, True)
•     if '$creq' in msg.topic: # 如果收到OneNET下发的主题，然后将信息转发给test主题，其他设备将会收到
•         (rc, final_mid) = client.publish('test', str(msg.payload), 2, True)
• def on_publish(mqttc, obj, mid):
•     print("Publish mid: " + str(mid))
•     pass
• def on_subscribe(mqttc, obj, mid, granted_qos):
•     print("Subscribed: " + str(mid) + " " + str(granted_qos))
• def on_log(mqttc, obj, level, string):
•     print("Log:" + string)
• if __name__ == '__main__':
•     client = mqtt.Client(client_id=clientid, clean_session=True, userdata=None, protocol=mqtt.MQTTv311, transport="tcp")
•     client.on_connect = on_connect
•     client.on_message = on_message
•     client.on_publish = on_publish
•     client.on_subscribe = on_subscribe
•     client.on_log = on_log
•     try:
•         # 配置用户名和密码
•         client.username_pw_set(username, password)
•         # 请根据实际情况改变MQTT代理服务器的IP地址
•         client.connect(hostname, port, 60)
•         # Blocking call that processes network traffic, dispatches callbacks and
•         # handles reconnecting.
•         # Other loop*() functions are available that give a threaded interface and a
•         # manual interface.
•         client.loop_forever()
•     except KeyboardInterrupt:
•         client.disconnect()