Datenstrom speichern

Du wirst jetzt einen MQTT-Datenstrom verwenden und jeden neuen Datenpunkt an die Liste store anhängen.

Mit der Bibliothek paho.mqtt kannst du dich mit subscribe.callback() auf einen Datenstrom abonnieren.

Jede neue Nachricht führt zu einem Aufruf unserer Funktion, die folgende Argumente haben muss:

client, die Client-Instanz für diesen Callback
userdata, die privaten Nutzerdaten, die bei der Erstellung der Instanz gesetzt wurden
message, eine Instanz von MQTTMessage. Für diese Übung interessiert uns nur das Attribut payload.

Du musst die Daten mit json.loads() als JSON-String parsen und an die Liste store anhängen. Anschließend wandelst du das Ganze in ein DataFrame um und speicherst das DataFrame als CSV-Datei.

json, pandas als pd, MQTT_HOST und topic stehen dir in deiner Session zur Verfügung.

Diese Übung ist Teil des Kurses

IoT-Daten in Python analysieren

Kurs anzeigen

Interaktive Übung

Vervollständige den Beispielcode, um diese Übung erfolgreich abzuschließen.

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

Code bearbeiten und ausführen