1. Learn
  2. /
  3. Courses
  4. /
  5. Analýza dat z IoT v Pythonu

Connected

Exercise

Ukládání datového streamu do mezipaměti

Teď budeš sbírat data ze 2 energetických čítačů. Jde o velmi minimalistický datový stream, který poskytuje pouze identifikátor měřicího zařízení a naměřenou hodnotu, oddělené čárkou.

Vypadá to takto: C331,6020

Protože samotné měření neobsahuje časový údaj, musíš se spoléhat na čas, kdy byla zpráva odeslána do MQTT brokeru. Tento časový razítko je dostupné jako message.timestamp ve formátu epoch.

Instructions 1/2

undefined XP
    1
    2
  • V rámci callback funkce spoj časové razítko zprávy a její payload, oddělené čárkou (,), a výsledek ulož jako data.
  • Přidej data do seznamu mezipaměti cache.