MQTT 單一訊息
想像以下情境: 你拿到了一個 MQTT Broker 位址與主題名稱,你需要撰寫程式碼來儲存資料串流的內容。
首先,先消費(接收)一則訊息,確認訊息的格式為何。
接著,你可以列印並檢視這則訊息,判斷後續該如何處理資料。
這會作為下一個練習的基礎;在下一個練習中,我們會訂閱資料串流並收集多則訊息。
本練習屬於課程
使用 Python 分析 IoT 資料
練習說明
- 將 MQTT 函式庫
paho.mqtt.subscribe以subscribe匯入。 - 從主題
"datacamp/iot/simple"取得一則訊息,並將結果儲存為msg。 - 列印該訊息的主題與負載,中間以逗號分隔。
動手互動練習
試著完成這個範例程式碼,體驗一下這個練習。
# Import mqtt library
import ____ as ____
# Retrieve one message
msg = ____.____(____, hostname="mqtt.datacamp.com")
# Print topic and payload
print(f"{____}, {____}")