使用python2.7測試通過，實現(xiàn)消息訂閱，發(fā)布，平臺數(shù)據(jù)下發(fā)，存儲功能。
　　一定要修改下面代碼
　　clientid = ‘8760549’ # 創(chuàng)建設(shè)備時得到的設(shè)備ID，為數(shù)字字串
　　username = ‘79581’ # 注冊產(chǎn)品時，平臺分配的產(chǎn)品ID，為數(shù)字字串
　　password = ‘iDO9cRe85v2wpgFm2hQsMiapP=U=’ # 為設(shè)備的鑒權(quán)信息（即唯一設(shè)備編號，SN），或者為apiKey，為字符串
　　安裝 sudo pip install paho-mqtt
　　關(guān)于paho的使用參考：https://pypi.python.org/pypi/paho-mqtt/1.3.0
　　實現(xiàn)功能：
　　平臺下發(fā)的數(shù)據(jù)，會轉(zhuǎn)發(fā)給訂閱了test主題的設(shè)備。收到主題為upload后，會將數(shù)據(jù)類型3:Json數(shù)據(jù)2的固定數(shù)據(jù){“a”：1，“c”：3，“b”：2，“d”：4}發(fā)給平臺。
　　樹莓派上也同樣適用。
　　不知道有沒有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服務(wù)器地址
　　port = 6002 # OneNET服務(wù)器端口地址
　　clientid = ‘8760549’ # 創(chuàng)建設(shè)備時得到的設(shè)備ID，為數(shù)字字串
　　username = ‘79581’ # 注冊產(chǎn)品時，平臺分配的產(chǎn)品ID，為數(shù)字字串
　　password = ‘iDO9cRe85v2wpgFm2hQsMiapP=U=’ # 為設(shè)備的鑒權(quán)信息（即唯一設(shè)備編號，SN），或者為apiKey，為字符串
　　topic1 = ‘$creq/#’ #訂閱平臺下發(fā)命令主題
　　topic2 = ‘upload’
　　# 連接成功回調(diào)函數(shù)
　　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） # 參數(shù)一為topic字符串， 參數(shù)二為QoS級別，默認QoS=0
　　client.subscribe（topic2）
　　# 消息推送回調(diào)函數(shù)
　　def on_message（client， userdata， msg）：
　　print（‘［topic：］’+msg.topic + ‘ ’ + ‘［payload：］’+str（msg.payload））
　　if msg.topic == ‘upload’： # 如果收到upload主題，就將數(shù)據(jù)類型3（json數(shù)據(jù)2）內(nèi)容上傳給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下發(fā)的主題，然后將信息轉(zhuǎn)發(fā)給test主題，其他設(shè)備將會收到
　　（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）
　　# 請根據(jù)實際情況改變MQTT代理服務(wù)器的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（）
?