Spara dataström

Nu ska du ta emot en MQTT-dataström och lägga till varje ny datapunkt i listan store.

Med biblioteket paho.mqtt kan du prenumerera på en dataström med hjälp av subscribe.callback().

Varje nytt meddelande resulterar i ett anrop till vår funktion, som måste ha följande argument:

client, klientinstansen för det här återanropet
userdata, privata användardata som anges när instansen skapas
message, en instans av MQTTMessage. I den här övningen är payload det enda attributet vi är intresserade av.

Du behöver tolka datan som en JSON-sträng med json.loads() och lägga till den i listan store. Därefter konverterar du den till en DataFrame och sparar den som en CSV-fil.

json, pandas som pd, MQTT_HOST och topic finns tillgängliga i din session.

Den här övningen är en del av kursen

Analysera IoT-data i Python

Visa kurs

Interaktiv övning med praktiskt arbete

Testa den här övningen genom att slutföra den här exempelkoden.

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

Redigera och kör kod