開始使用免費開始

儲存資料串流

你現在要接收一個 MQTT 資料串流,並將每個新到的資料點附加到清單 store

使用 paho.mqtt 函式庫,你可以用 subscribe.callback() 訂閱資料串流。

每一則新訊息都會呼叫我們的函式一次,該函式需要以下參數:

  • client,此回呼的用戶端實例。
  • userdata,在建立實例時設定的私有使用者資料。
  • messageMQTTMessage 的實例。本練習中,我們只需要 payload 這個屬性。

你需要使用 json.loads() 將資料解析為 JSON 字串,並將其附加到清單 store。 接著,將它轉換為 DataFrame,並把該 DataFrame 儲存為 CSV 檔案。

jsonpandas(匯入為 pd)、MQTT_HOSTtopic 已在你的工作階段中可用。

本練習屬於課程

使用 Python 分析 IoT 資料

檢視課程

動手互動練習

試著完成這個範例程式碼,體驗一下這個練習。

# Define function to call by callback method
def ____(____):
    # Parse the message.payload
    data = ____
    store.append(data)
編輯並執行程式碼