開始使用免費開始

快取資料串流

你現在要從 2 個能耗計數器蒐集資料。 這是一個非常精簡的資料串流,只提供量測裝置與數值,兩者以逗號分隔。

看起來如下: C331,6020

由於量測本身沒有時間戳,你需要依賴訊息送到 MQTT broker 的時間。 這個時間戳以 epoch 格式提供,能以 message.timestamp 取得。

本練習屬於課程

使用 Python 分析 IoT 資料

檢視課程

動手互動練習

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

cache = []

def on_message(client, userdata, message):
 	# Combine timestamp and payload
    data = f"{____.____},{____.____}"
    # Append data to cache
    ____.____(____)

# Connect function to mqtt datastream
subscribe.callback(on_message, topics="datacamp/energy", hostname=MQTT_HOST)
編輯並執行程式碼