5.4 KiB
將您的 IoT 裝置連接到雲端 - 虛擬 IoT 硬體與 Raspberry Pi
在本課程的這部分,您將把虛擬 IoT 裝置或 Raspberry Pi 連接到 IoT Hub,以傳送遙測數據並接收指令。
將裝置連接到 IoT Hub
下一步是將您的裝置連接到 IoT Hub。
任務 - 連接到 IoT Hub
-
在 VS Code 中打開
soil-moisture-sensor
資料夾。如果您使用的是虛擬 IoT 裝置,請確保終端中虛擬環境已啟動。 -
安裝一些額外的 Pip 套件:
pip3 install azure-iot-device
azure-iot-device
是一個用於與 IoT Hub 通訊的函式庫。 -
在
app.py
文件的頂部,現有的匯入語句下方,添加以下匯入語句:from azure.iot.device import IoTHubDeviceClient, Message, MethodResponse
此程式碼匯入了與 IoT Hub 通訊的 SDK。
-
移除
import paho.mqtt.client as mqtt
這行,因為此函式庫已不再需要。移除所有 MQTT 相關程式碼,包括主題名稱、所有使用mqtt_client
的程式碼以及handle_command
。保留while True:
迴圈,只需刪除該迴圈中的mqtt_client.publish
行即可。 -
在匯入語句下方添加以下程式碼:
connection_string = "<connection string>"
將
<connection string>
替換為您在本課程早些時候為裝置檢索到的連接字串。💁 這並非最佳做法。連接字串不應存儲在原始程式碼中,因為它可能被檢入版本控制系統並被任何人發現。我們在此處這樣做是為了簡化操作。理想情況下,您應使用環境變數和像
python-dotenv
這樣的工具。您將在後續課程中學到更多相關內容。 -
在此程式碼下方,添加以下程式碼以建立一個可以與 IoT Hub 通訊的裝置客戶端物件並連接它:
device_client = IoTHubDeviceClient.create_from_connection_string(connection_string) print('Connecting') device_client.connect() print('Connected')
-
執行此程式碼。您將看到您的裝置已成功連接。
pi@raspberrypi:~/soil-moisture-sensor $ python3 app.py Connecting Connected Soil moisture: 379
傳送遙測數據
現在您的裝置已連接,您可以將遙測數據傳送到 IoT Hub,而不是 MQTT broker。
任務 - 傳送遙測數據
-
在
while True
迴圈內,睡眠之前添加以下程式碼:message = Message(json.dumps({ 'soil_moisture': soil_moisture })) device_client.send_message(message)
此程式碼建立了一個包含土壤濕度讀數的 JSON 字串的 IoT Hub
Message
,然後將其作為裝置到雲端的訊息傳送到 IoT Hub。
處理指令
您的裝置需要處理來自伺服器程式碼的指令,以控制繼電器。這是通過直接方法請求發送的。
任務 - 處理直接方法請求
-
在
while True
迴圈之前添加以下程式碼:def handle_method_request(request): print("Direct method received - ", request.name) if request.name == "relay_on": relay.on() elif request.name == "relay_off": relay.off()
此程式碼定義了一個方法
handle_method_request
,當 IoT Hub 呼叫直接方法時會執行。每個直接方法都有一個名稱,此程式碼預期方法名稱為relay_on
用於打開繼電器,以及relay_off
用於關閉繼電器。💁 這也可以通過單一的直接方法請求來實現,將繼電器的期望狀態作為有效負載傳遞,該有效負載可以通過方法請求傳遞並從
request
物件中獲取。 -
直接方法需要一個回應,以告知呼叫程式碼該方法已被處理。在
handle_method_request
函數的末尾添加以下程式碼,以建立對請求的回應:method_response = MethodResponse.create_from_method_request(request, 200) device_client.send_method_response(method_response)
此程式碼向直接方法請求發送一個 HTTP 狀態碼為 200 的回應,並將其返回給 IoT Hub。
-
在此函數定義下方添加以下程式碼:
device_client.on_method_request_received = handle_method_request
此程式碼告訴 IoT Hub 客戶端在呼叫直接方法時執行
handle_method_request
函數。
💁 您可以在 code/pi 或 code/virtual-device 資料夾中找到此程式碼。
😀 您的土壤濕度感測器程式已成功連接到您的 IoT Hub!
免責聲明:
本文件已使用 AI 翻譯服務 Co-op Translator 進行翻譯。雖然我們努力確保翻譯的準確性,但請注意,自動翻譯可能包含錯誤或不準確之處。原始文件的母語版本應被視為權威來源。對於關鍵信息,建議使用專業人工翻譯。我們對因使用此翻譯而引起的任何誤解或誤釋不承擔責任。