MQTT – un singur mesaj
Imaginează-ți următorul scenariu: Ți s-au oferit adresa unui broker MQTT și numele unui topic, iar sarcina ta este să scrii cod care să stocheze conținutul fluxului de date.
Mai întâi, verifică în ce format vor sosi mesajele, preluând un singur mesaj.
Poți apoi să afișezi și să inspectezi mesajul pentru a decide cum să procesezi datele în continuare.
Aceasta va fi baza pentru exercițiul următor, în care te vei abona la fluxul de date și vei colecta mai multe mesaje.
Acest exercițiu face parte din cursul
Analiza datelor IoT în Python
Instrucțiuni pentru exercițiu
- Importă biblioteca MQTT
paho.mqtt.subscribecu aliasulsubscribe. - Preia un singur mesaj din topicul
"datacamp/iot/simple"și stochează rezultatul în variabilamsg. - Afișează topicul și payload-ul mesajului, separate printr-o virgulă.
Exercițiu interactiv practic
Încearcă acest exercițiu completând acest cod de exemplu.
# Import mqtt library
import ____ as ____
# Retrieve one message
msg = ____.____(____, hostname="mqtt.datacamp.com")
# Print topic and payload
print(f"{____}, {____}")