Mensaje único MQTT
Imagina el siguiente escenario: Te han dado la dirección de un broker MQTT y el nombre de un tema (topic), y tienes que escribir código para almacenar el contenido del flujo de datos.
Primero, deberías comprobar en qué formato llegan los mensajes consumiendo un único mensaje.
Luego podrás imprimir e inspeccionar el mensaje para decidir cómo procesar los datos posteriormente.
Esta será la base para el siguiente ejercicio, donde nos suscribiremos al flujo de datos y recopilaremos múltiples mensajes.
Este ejercicio forma parte del curso
Análisis de datos de IoT en Python
Instrucciones del ejercicio
- Importa la biblioteca MQTT
paho.mqtt.subscribecomosubscribe. - Recupera un mensaje del topic
"datacamp/iot/simple"y guarda el resultado comomsg. - Imprime el topic y el payload del mensaje, separados por una coma.
Ejercicio interactivo práctico
Prueba este ejercicio y completa el código de muestra.
# Import mqtt library
import ____ as ____
# Retrieve one message
msg = ____.____(____, hostname="mqtt.datacamp.com")
# Print topic and payload
print(f"{____}, {____}")