MQTT ข้อความเดียว
ลองนึกภาพสถานการณ์ต่อไปนี้: ได้รับที่อยู่ MQTT Broker และชื่อ topic มา และต้องเขียนโค้ดเพื่อจัดเก็บข้อมูลจาก Datastream
ขั้นแรก ควรตรวจสอบก่อนว่าข้อความที่รับมานั้นอยู่ในรูปแบบใด โดยดึงข้อความเพียงข้อความเดียวมาก่อน
จากนั้นพิมพ์และตรวจสอบข้อความนั้น เพื่อพิจารณาว่าจะประมวลผลข้อมูลต่อไปอย่างไร
นี่จะเป็นพื้นฐานสำหรับแบบฝึกหัดถัดไป ซึ่งจะสมัครรับ data stream และเก็บข้อความหลายข้อความพร้อมกัน
แบบฝึกหัดนี้เป็นส่วนหนึ่งของหลักสูตร
การวิเคราะห์ข้อมูล IoT ด้วย Python
คำแนะนำการฝึกหัด
- นำเข้าไลบรารี MQTT
paho.mqtt.subscribeในชื่อsubscribe - ดึงข้อความหนึ่งข้อความจาก topic
"datacamp/iot/simple"แล้วเก็บผลลัพธ์ไว้ในตัวแปรmsg - พิมพ์ topic และ payload จากข้อความ โดยคั่นด้วยเครื่องหมายจุลภาค
แบบฝึกหัดเชิงโต้ตอบแบบลงมือทำ
ลองทำแบบฝึกหัดนี้โดยเติมโค้ดตัวอย่างนี้ให้สมบูรณ์
# Import mqtt library
import ____ as ____
# Retrieve one message
msg = ____.____(____, hostname="mqtt.datacamp.com")
# Print topic and payload
print(f"{____}, {____}")