Veri Akışını Önbelleğe Al
Şimdi 2 enerji sayacından veri toplayacaksın. Bu, yalnızca ölçüm cihazını ve değeri virgülle ayırarak veren, oldukça minimal bir veri akışı.
Şu şekilde görünür:
C331,6020
Ölçümün içinde zaman bilgisi olmadığından, MQTT aracısına (broker) iletinin gönderildiği zamana güvenmen gerekiyor.
Bu zaman damgası, epoch biçiminde message.timestamp olarak mevcut.
Bu egzersiz, kursun bir parçasıdır
Python ile IoT Verilerini Analiz Etmek
Uygulamalı etkileşimli egzersiz
Bu egzersizi bu örnek kodu tamamlayarak deneyin.
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)