Cache Datastream
ตอนนี้จะรวบรวมข้อมูลจากมิเตอร์พลังงาน 2 ตัว นี่คือสตรีมข้อมูลแบบเรียบง่าย ซึ่งให้เฉพาะชื่ออุปกรณ์วัดและค่าที่วัดได้ คั่นด้วยเครื่องหมายจุลภาค
มีรูปแบบดังนี้:
C331,6020
เนื่องจากในการวัดไม่มีข้อมูลเวลากำกับ จึงต้องอาศัยเวลาที่ส่งข้อความไปยัง MQTT broker แทน
ค่า timestamp นี้ดึงได้จาก message.timestamp ในรูปแบบ epoch
แบบฝึกหัดนี้เป็นส่วนหนึ่งของหลักสูตร
การวิเคราะห์ข้อมูล IoT ด้วย Python
แบบฝึกหัดเชิงโต้ตอบแบบลงมือทำ
ลองทำแบบฝึกหัดนี้โดยเติมโค้ดตัวอย่างนี้ให้สมบูรณ์
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)