บันทึก Datastream

ในแบบฝึกหัดนี้ คุณจะรับข้อมูลจาก MQTT Data stream แล้วเพิ่มข้อมูลแต่ละจุดต่อท้ายลิสต์ store

ด้วยไลบรารี paho.mqtt สามารถ subscribe กับ data stream ได้โดยใช้ subscribe.callback()

ข้อความใหม่แต่ละข้อความจะเรียกฟังก์ชันของเราหนึ่งครั้ง โดยฟังก์ชันดังกล่าวต้องรับอาร์กิวเมนต์ต่อไปนี้:

client — อินสแตนซ์ของ client สำหรับ callback นี้
userdata — ข้อมูลส่วนตัวของผู้ใช้ที่กำหนดไว้ตอนสร้างอินสแตนซ์
message — อินสแตนซ์ของ MQTTMessage ในแบบฝึกหัดนี้ แอตทริบิวต์ที่ต้องใช้คือ payload เท่านั้น

ให้แปลงข้อมูลจาก JSON string โดยใช้ json.loads() แล้วเพิ่มต่อท้ายลิสต์ store จากนั้นแปลงเป็น DataFrame และบันทึกเป็นไฟล์ CSV

json, pandas ในชื่อ pd, MQTT_HOST และ topic พร้อมใช้งานในเซสชันของคุณแล้ว

แบบฝึกหัดนี้เป็นส่วนหนึ่งของหลักสูตร

การวิเคราะห์ข้อมูล IoT ด้วย Python

ลองทำแบบฝึกหัดนี้โดยเติมโค้ดตัวอย่างนี้ให้สมบูรณ์

# Define function to call by callback method
def ____(____):
    # Parse the message.payload
    data = ____
    store.append(data)