MQTT の単一メッセージ
次のようなシナリオを想定してください。 MQTT ブローカーのアドレスとトピック名が与えられており、データストリームの内容を保存するコードを書く必要があります。
まず、単一のメッセージを受信して、メッセージがどのような形式になっているかを確認しましょう。
その後、メッセージを出力して内容を確認し、データをどのように処理すればよいかを見極めます。
これは次の演習の土台となります。次の演習では、データストリームを購読して複数のメッセージを収集します。
この演習はコースの一部です
Python による IoT データの分析
演習の手順
- MQTT ライブラリ
paho.mqtt.subscribeをsubscribeとしてインポートします。 - トピック
"datacamp/iot/simple"から 1 件のメッセージを取得し、結果をmsgとして保存します。 - メッセージのトピックとペイロードを、カンマで区切って出力します。
実践的なインタラクティブ演習
このサンプルコードを完成させて、この演習に挑戦してみましょう。
# Import mqtt library
import ____ as ____
# Retrieve one message
msg = ____.____(____, hostname="mqtt.datacamp.com")
# Print topic and payload
print(f"{____}, {____}")