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.
Toto cvičení je součástí kurzu
Analýza dat z IoT v Pythonu
Interaktivní cvičení na vyzkoušení si v praxi
Vyzkoušejte si toto cvičení dokončením tohoto ukázkového kódu.
cache = []
def on_message(client, userdata, message):
# Combine timestamp and payload
data = f"{____.____},{____.____}"
# Append data to cache
____.____(____)
# Connect function to mqtt datastream
subscribe.callback(on_message, topics="datacamp/energy", hostname=MQTT_HOST)