Salva il flusso di dati
Ora prenderai un flusso di dati MQTT e aggiungerai ogni nuovo punto dati alla lista store.
Usando la libreria paho.mqtt, puoi iscriverti a un flusso di dati con subscribe.callback().
Ogni nuovo messaggio comporterà una chiamata alla nostra funzione, che deve avere i seguenti argomenti:
client, l'istanza del client per questa callbackuserdata, i dati utente privati impostati alla creazione dell'istanzamessage, un'istanza diMQTTMessage. Per questo esercizio,payloadè l'unico attributo che ci interessa.
Devi analizzare i dati come stringa JSON usando json.loads() e aggiungerli alla lista store.
Poi li convertirai in un DataFrame e salverai il DataFrame come file CSV.
json, pandas come pd, MQTT_HOST e topic sono disponibili nella tua sessione.
Questo esercizio fa parte del corso
Analizzare i dati IoT in Python
Esercizio pratico interattivo
Prova a risolvere questo esercizio completando il codice di esempio.
# Define function to call by callback method
def ____(____):
# Parse the message.payload
data = ____
store.append(data)