快取資料串流
你現在要從 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)