Salvează fluxul de date

Acum vei prelua un flux de date MQTT și vei adăuga fiecare punct de date nou în lista store.

Using the library paho.mqtt, you can subscribe to a data stream using subscribe.callback().

Fiecare mesaj nou va genera un apel al funcției noastre, care trebuie să aibă următorii parametri:

client, instanța clientului pentru acest callback
userdata, datele private ale utilizatorului, setate la crearea instanței
message, o instanță de tip MQTTMessage. Pentru acest exercițiu, singurul atribut care ne interesează este payload.

Trebuie să parsezi datele ca șir JSON folosind json.loads() și să le adaugi în lista store. Apoi vei converti aceasta într-un DataFrame și vei salva DataFrame-ul ca fișier CSV.

json, pandas as pd, MQTT_HOST și topic sunt disponibile în sesiunea ta.

Acest exercițiu face parte din cursul

Analiza datelor IoT în Python

Vezi cursul

Exercițiu interactiv practic

Încearcă acest exercițiu completând acest cod de exemplu.

# Define function to call by callback method
def ____(____):
    # Parse the message.payload
    data = ____
    store.append(data)

Editează și rulează codul