搭建整套物聯網系統的方法有很多，最近四處搗鼓，使用python + 阿里雲搭建一套最簡單的物聯系統，可以將單片機上的數據通過阿里雲傳輸到PC端。
注意：很多人學Python過程中會遇到各種煩惱問題，沒有人解答容易放棄。為此小編建了個Python全棧免費答疑.裙 ：七衣衣九七七巴而五（數字的諧音）轉換下可以找到了，不懂的問題有老司機解決里面還有最新Python實戰教程免非下,，一起相互監督共同進步！
一、基本結構
先看架構圖
二、設備端接入
物聯網終端是用的ESP32，是一款自帶藍牙和Wifi的單片機。利用它可以直接接入互聯網，無需其他模塊。當然你可以將現在流行的NB-Iot模塊來聯網，不過需要自己寫一下驅動程序。我買的模塊是支持micropython開發的，在淘寶上可以搜索到，用起來很方便。有時間我會補上這一塊的初步教程。
Micropython是可以在低端硬件上運行的python,可以使用python語言直接操作IO 和MCU的外設比如UART、I2C等，用起來非常方便，不要搭建復雜的開發環境，也不需要學習寄存器配置。作為一個對傳統MCU開發非常熟悉的硬件工程師來說，感覺操作起來非常簡單。目前Micropython已經支持很多硬件了，應該用比較廣泛的STM32部分系列也被支持。Micropython也已經支持很多常用的庫，比如藍牙，telnet，mqtt等。下面這個鏈接是micropython的中文論壇。
http://www.micropython.org.cn/bbs/forum.php
ESP32 通過wifi 接入互聯網，使用mqtt協議接入阿里雲，將溫度數據上傳至阿里雲。在雲端通過消息訂閱可以直接查看溫度信息。在PC端使用python調用MQTT協議，接入到阿里雲。但是PC端和ESP32在阿里雲上是兩個不同的設備，需要通過阿里雲來轉發信息，這樣PC就可以拿到ESP32上傳的數據了。
ESP32 上的代碼如下：
from umqtt.simple import MQTTClient import usocket as socket import time import wifi wifi.connect() #Demo_01 ProductKey = "*********"#使用你自己的 ClientId = "1234|securemode=3,signmethod=hmacsha1|" DeviceName = "Demo_01" DeviceSecret = "*******************************"#使用你自己的 strBroker = ProductKey + ".iot-as-mqtt.cn-shanghai.aliyuncs.com" Brokerport = 1883 user_name = "Demo_01&*********"#使用你自己的 user_password = "**********************************************"#使用你自己的 print("clientid:",ClientId,"\n","Broker:",strBroker,"\n","User Name:",user_name,"\n","Password:",user_password,"\n") def connect(): client = MQTTClient(client_id = ClientId,server= strBroker,port=Brokerport,user=user_name, password=user_password,keepalive=60) #please make sure keepalive value is not 0 client.connect() temperature =25.00 while temperature < 30: temperature += 0.5 send_mseg = '{"params": {"IndoorTemperature": %s},"method": "thing.event.property.post"}' % (temperature) client.publish(topic="/sys/*************/Demo_01/thing/event/property/post", msg=send_mseg,qos=1, retain=False)#*號處為product id time.sleep(3) while True: pass #client.disconnect() 有幾點需要說明：
1.代碼中的wifi.connect()函數需要自己編寫，網上能搜到類似的，也可以打賞私信我所要源碼。
2.阿里雲物聯網平台的接入需要進行三元組認證，會根據一定的規則生成登錄名和密碼，這個網上信息還是比較全面的。
3.向阿里雲物聯網平台發布消息的格式一定要按照代碼中所寫，網上很多代碼，但是對這一塊的描述都不清楚。
- Micropython使用的umqtt.simple庫，一定要設置keepalive時間，否則無法連接。這一點我是摸索了好久，最終通過查看庫的源碼才發現的問題。
三、雲端設置
在雲端建立一個高級產品，並創建兩個設備，以供ESP32 和PC連接。
需要在產品中定義一下功能。
雲端和設備端都建立好了之后，可以查看設備運行狀態看到數據上傳
這是查看數據記錄得到的結果
當你看到正確的數據之后，就說明你的成功接入物聯網並上傳了數據。
接下來就是最重要的部分——設置是使用規則引擎來進行數據轉發，將設備demo_01的數據轉發到demo_02。這一步的語法很重要，雖然有官網有詳細教程，但是當時還是搞了好久才完全正確。
規則查詢語句：
SELECT items.IndoorTemperature.value as IndoorTemperature FROM "/sys/use-your-productkey-here/Demo_01/thing/event/property/post" WHERE items.IndoorTemperature.value > 0 四、PC端接入
PC 端使用python模擬MQTT設備登陸阿里雲訂閱消息就行了，只要裝好python很快就可以實現，網上也有很多代碼。代碼的很大一部分就是在做三元組認證，可以將這部分稍微修改一下來計算ESP32 登陸時所需的
PC端python代碼如下：
# coding=utf-8 import datetime import time import hmac import hashlib import math try: import paho.mqtt.client as mqtt except ImportError: print("MQTT client not find. Please install as follow:") print("pip install paho-mqtt") # 設置連接信息 #Demo_02 ProductKey = "*********"#使用你自己的 ClientId = "2234" # 自定義clientId DeviceName = "Demo_02" DeviceSecret ="************************************8**"#使用你自己的 # 獲取時間戳（當前時間毫秒值） us = math.modf(time.time())[0] ms = int(round(us * 1000)) timestamp = str(ms) # 計算密碼（簽名值） def calculation_sign(signmethod): data = "".join(("clientId", ClientId, "deviceName", DeviceName, "productKey", ProductKey, "timestamp", timestamp)) if "hmacsha1" == signmethod: # ret = hmac.new(bytes(DeviceSecret), # bytes(data), hashlib.sha1).hexdigest() ret = hmac.new(bytes(DeviceSecret, encoding="utf-8"), bytes(data, encoding="utf-8"), hashlib.sha1).hexdigest() elif "hmacmd5" == signmethod: # ret = hmac.new(bytes(DeviceSecret, encoding="utf-8"), # bytes(data, encoding="utf-8"), hashlib.md5).hexdigest() ret = hmac.new(bytes(DeviceSecret, encoding="utf-8"), bytes(data, encoding="utf-8"), hashlib.md5).hexdigest() else: raise ValueError return ret # ====================================================== strBroker = ProductKey + ".iot-as-mqtt.cn-shanghai.aliyuncs.com" port = 1883 client_id = "".join((ClientId, "|securemode=3", ",signmethod=", "hmacsha1", ",timestamp=", timestamp, "|")) username = "".join((DeviceName, "&", ProductKey)) password = calculation_sign("hmacsha1") print("="*60) print(strBroker) print("client_id:", client_id) print("username:", username) print("password:", password) print("="*60) # 成功連接后的操作 def on_connect(client, userdata, flags, rc): print("OnConnetc, rc: " + str(rc)) # 成功發布消息的操作 def on_publish(client, msg, rc): if rc == 0: print("publish success, msg = " + msg)