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
Python ile IoT Verilerini Analiz Etmek
kursunun bir parçasıdırUygulamalı interaktif egzersiz
Bu örnek kodu tamamlayarak bu egzersizi bitirin.
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)