Memorează în cache fluxul de date
Vei colecta acum date de la 2 contoare de energie. Acesta este un flux de date foarte minimalist, care furnizează doar dispozitivul de măsurare și valoarea, separate printr-o virgulă.
Arată astfel:
C331,6020
Deoarece măsurătoarea în sine nu conține informații despre timp, trebuie să te bazezi pe momentul în care mesajul a fost transmis brokerului MQTT.
Acest timestamp este disponibil ca message.timestamp în format epoch.
Acest exercițiu face parte din cursul
Analiza datelor IoT în Python
Exercițiu interactiv practic
Încearcă acest exercițiu completând acest cod de exemplu.
cache = []
def on_message(client, userdata, message):
# Combine timestamp and payload
data = f"{____.____},{____.____}"
# Append data to cache
____.____(____)
# Connect function to mqtt datastream
subscribe.callback(on_message, topics="datacamp/energy", hostname=MQTT_HOST)