Тепер ви візьмете поток даних MQTT і додаватимете кожну нову точку даних до списку store.

За допомогою бібліотеки paho.mqtt ви можете підписатися на поток даних через subscribe.callback().

Кожне нове повідомлення призведе до одного виклику нашої функції, яка має мати такі аргументи:

client — екземпляр клієнта для цього зворотного виклику
userdata — приватні користувацькі дані, задані під час створення екземпляра
message — екземпляр MQTTMessage. У цій вправі нас цікавить лише атрибут payload.

Вам потрібно розібрати дані як рядок JSON за допомогою json.loads() і додати їх до списку store. Потім перетворіть це на DataFrame і збережіть DataFrame як файл CSV.

json, pandas як pd, MQTT_HOST і topic доступні у вашій сесії.

Що таке MQTT

Аналіз даних IoT у Python

Практична інтерактивна вправа