データストリームを保存する

ここでは、MQTT データストリームを取得し、新しいデータポイントが届くたびにリスト store に追加していきます。

paho.mqtt ライブラリを使うと、subscribe.callback() でデータストリームを購読（サブスクライブ）できます。

新しいメッセージが届くたびに、関数が1回呼び出されます。この関数には、次の引数が必要です。

データを json.loads() を使って JSON 文字列としてパースし、リスト store に追加する必要があります。その後、このデータを 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)