Cachelagra dataström
Nu ska du samla in data från 2 energimätare. Det här är en mycket minimalistisk dataström som bara innehåller mätenheten och värdet, separerade med ett kommatecken.
Det ser ut så här:
C331,6020
Eftersom mätningen inte innehåller någon tidsinformation behöver du förlita dig på den tid då meddelandet skickades till MQTT-brokern.
Den tidsstämpeln finns tillgänglig som message.timestamp i epoch-format.
Den här övningen är en del av kursen
Analysera IoT-data i Python
Interaktiv övning med praktiskt arbete
Testa den här övningen genom att slutföra den här exempelkoden.
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)