Datastream opslaan

Je gaat nu een MQTT-datastream gebruiken en elk nieuw datapunt toevoegen aan de lijst store.

Met de bibliotheek paho.mqtt kun je je abonneren op een datastream met subscribe.callback().

Elk nieuw bericht zorgt voor één aanroep van onze functie, die de volgende argumenten moet hebben:

client, de clientinstantie voor deze callback
userdata, de privégebruikersdata die is ingesteld bij het maken van de instantie
message, een instantie van MQTTMessage. Voor deze oefening zijn we alleen geïnteresseerd in het attribuut payload.

Je moet de data parsen als JSON-string met json.loads() en toevoegen aan de lijst store. Zet dit daarna om naar een DataFrame en sla het DataFrame op als CSV-bestand.

json, pandas als pd, MQTT_HOST en topic zijn beschikbaar in je sessie.

Deze oefening maakt deel uit van de cursus

IoT-gegevens analyseren in Python

Bekijk cursus

Interactieve oefening met praktijkervaring

Probeer deze oefening door deze voorbeeldcode aan te vullen.

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

Code bewerken en uitvoeren