1. Nauka
    2. /
  2. Kursy
    3. /
  3. Analiza danych IoT w Pythonie
Connected

ćwiczenie

Zapisywanie strumienia danych

Teraz pobierzesz strumień danych MQTT i będziesz dołączać każdy nowy punkt danych do listy store.

Używając biblioteki paho.mqtt, możesz subskrybować strumień danych za pomocą subscribe.callback().

Każda nowa wiadomość spowoduje jedno wywołanie naszej funkcji, która musi przyjmować następujące argumenty:

  • client – instancja klienta dla tego wywołania zwrotnego
  • userdata – prywatne dane użytkownika ustawione podczas tworzenia instancji
  • message – instancja klasy MQTTMessage. W tym ćwiczeniu interesuje nas wyłącznie atrybut payload.

Musisz sparsować dane jako ciąg JSON za pomocą json.loads() i dołączyć wynik do listy store. Następnie przekształcisz tę listę w DataFrame i zapiszesz go jako plik CSV.

json, pandas jako pd, MQTT_HOST oraz topic są dostępne w twojej sesji.

Instrukcje 1/2

undefined XP
    1
    2
  • Utwórz funkcję on_message z wymaganymi parametrami.
  • Sparsuj message.payload jako JSON i dołącz wynik do listy data.