Uložení datového streamu

Teď vezmeš MQTT datový stream a každý nový datový bod přidáš do seznamu store.

S knihovnou paho.mqtt se můžeš přihlásit k odběru datového streamu pomocí subscribe.callback().

Každá nová zpráva vyvolá jedno volání naší funkce, která musí mít následující argumenty:

client – instance klienta pro tento callback
userdata – privátní uživatelská data nastavená při vytváření instance
message – instance MQTTMessage. V tomto cvičení nás zajímá pouze atribut payload.

Data je potřeba načíst jako JSON řetězec pomocí json.loads() a přidat je do seznamu store. Následně je převedeš na DataFrame a uložíš jako CSV soubor.

V session máš k dispozici json, pandas jako pd, MQTT_HOST a topic.

Toto cvičení je součástí kurzu

Analýza dat z IoT v Pythonu

Zobrazit kurz

Interaktivní cvičení na vyzkoušení si v praxi

Vyzkoušejte si toto cvičení dokončením tohoto ukázkového kódu.

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

Upravit a spustit kód