Cache Data Stream
Sekarang Anda akan mengumpulkan data dari 2 pencacah energi. Ini adalah data stream yang sangat minimalis, yang hanya menyediakan perangkat pengukuran dan nilainya, dipisahkan oleh koma.
Contohnya seperti berikut:
C331,6020
Karena tidak ada waktu pada pengukuran itu sendiri, Anda perlu mengandalkan waktu saat pesan dikirim ke broker MQTT.
Stempel waktunya tersedia sebagai message.timestamp dalam format epoch.
Latihan ini merupakan bagian dari kursus
Menganalisis Data IoT dengan Python
Latihan interaktif langsung praktik
Cobalah latihan ini dengan melengkapi kode contoh ini.
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)