1. Učit se
    2. /
  2. Kurzy
    3. /
  3. Analýza dat z IoT v Pythonu
Connected

cvičení

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.

Pokyny 1/2

undefined XP
    1
    2
  • Vytvoř funkci on_message s požadovanými parametry.
  • Načti message.payload jako JSON a přidej ho do seznamu data.