Збереження потоку даних

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

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

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

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

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

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

Ця вправа є частиною курсу

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

Переглянути курс

Інтерактивна практична вправа

Спробуйте виконати цю вправу, доповнивши цей зразок коду.

# Define function to call by callback method
def ____(____):
    # Parse the message.payload
    data = ____
    store.append(data)

Редагувати та запускати код