データストリームをキャッシュする
ここでは、2つのエネルギーカウンターからデータを収集します。 これは非常にシンプルなデータストリームで、測定デバイスと値をカンマで区切って提供するだけです。
次のような形式です。
C331,6020
測定値自体には時刻情報が含まれていないため、メッセージが MQTT ブローカーに送信された時刻を利用する必要があります。
このタイムスタンプは、エポック形式で 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)