Сохранение потока данных

Теперь вы будете получать данные из потока MQTT и добавлять каждую новую точку данных в список store.

С помощью библиотеки paho.mqtt можно подписаться на поток данных, используя subscribe.callback().

Каждое новое сообщение вызывает нашу функцию, которая должна принимать следующие аргументы:

client — экземпляр клиента для данного обратного вызова;
userdata — приватные пользовательские данные, заданные при создании экземпляра;
message — экземпляр MQTTMessage. В этом упражнении нас интересует только атрибут payload.

Необходимо разобрать данные как строку JSON с помощью json.loads() и добавить результат в список store. Затем преобразуйте список в DataFrame и сохраните его как CSV-файл.

json, pandas как pd, а также переменные MQTT_HOST и topic доступны в вашей сессии.

Это упражнение является частью курса

Анализ данных Интернета вещей на Python

Посмотреть курс

Интерактивное практическое упражнение

Попробуйте выполнить это упражнение, дополнив этот пример кода.

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

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