Одиночное сообщение MQTT

Представьте следующую ситуацию: Вам предоставлены адрес MQTT-брокера и название топика, и вам нужно написать код для сохранения содержимого потока данных.

Для начала стоит проверить, в каком формате поступают сообщения — для этого достаточно получить одно сообщение.

Затем вы сможете вывести его на экран и определить, как обрабатывать данные дальше.

Это станет основой для следующего упражнения, в котором мы подпишемся на поток данных и будем получать сразу несколько сообщений.

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

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

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

Инструкции к упражнению

Импортируйте библиотеку MQTT paho.mqtt.subscribe как subscribe.
Получите одно сообщение из топика "datacamp/iot/simple" и сохраните результат в переменную msg.
Выведите топик и содержимое сообщения через запятую.

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

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

# Import mqtt library
import ____ as ____

# Retrieve one message
msg = ____.____(____, hostname="mqtt.datacamp.com")

# Print topic and payload
print(f"{____}, {____}")

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