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

Connected

ćwiczenie

Buforowanie strumienia danych

Teraz będziesz zbierać dane z 2 liczników energii. To bardzo minimalistyczny strumień danych, który dostarcza jedynie identyfikator urządzenia pomiarowego i jego wartość, oddzielone przecinkiem.

Wygląda to następująco: C331,6020

Ponieważ sam pomiar nie zawiera informacji o czasie, musisz polegać na momencie przesłania wiadomości do brokera MQTT. Ten znacznik czasu jest dostępny jako message.timestamp w formacie epoch.

Instrukcje 1/2

undefined XP
    1
    2
  • Wewnątrz funkcji zwrotnej połącz znacznik czasu wiadomości i jej zawartość, oddzielając je przecinkiem (,), i zapisz wynik jako data.
  • Dołącz data do listy buforującej cache.