儲存資料串流
你現在要接收一個 MQTT 資料串流,並將每個新到的資料點附加到清單 store。
使用 paho.mqtt 函式庫,你可以用 subscribe.callback() 訂閱資料串流。
每一則新訊息都會呼叫我們的函式一次,該函式需要以下參數:
client,此回呼的用戶端實例。userdata,在建立實例時設定的私有使用者資料。message,MQTTMessage的實例。本練習中,我們只需要payload這個屬性。
你需要使用 json.loads() 將資料解析為 JSON 字串,並將其附加到清單 store。
接著,將它轉換為 DataFrame,並把該 DataFrame 儲存為 CSV 檔案。
json、pandas(匯入為 pd)、MQTT_HOST 與 topic 已在你的工作階段中可用。
本練習屬於課程
使用 Python 分析 IoT 資料
動手互動練習
試著完成這個範例程式碼,體驗一下這個練習。
# Define function to call by callback method
def ____(____):
# Parse the message.payload
data = ____
store.append(data)