Mensagem única via MQTT
Imagine o seguinte cenário: Você recebeu o endereço de um broker MQTT e o nome de um tópico, e precisa escrever um código para armazenar o conteúdo do fluxo de dados.
Primeiro, você deve verificar em que formato as mensagens chegam consumindo uma única mensagem.
Depois, você pode imprimir e inspecionar a mensagem para decidir como processar os dados.
Essa será a base para o próximo exercício, em que vamos assinar o fluxo de dados e coletar várias mensagens.
Este exercício faz parte do curso
Analisando Dados de IoT em Python
Instruções do exercício
- Importe a biblioteca MQTT
paho.mqtt.subscribecomosubscribe. - Recupere uma mensagem do tópico
"datacamp/iot/simple"e armazene o resultado emmsg. - Imprima o tópico e o payload da mensagem, separados por vírgula.
Exercício interativo prático
Experimente este exercício completando este código de exemplo.
# Import mqtt library
import ____ as ____
# Retrieve one message
msg = ____.____(____, hostname="mqtt.datacamp.com")
# Print topic and payload
print(f"{____}, {____}")