MQTT: một thông điệp đơn lẻ
Hãy hình dung kịch bản sau: Bạn được cung cấp địa chỉ MQTT Broker và tên một topic, và bạn cần viết mã để lưu nội dung của luồng dữ liệu (Datastream).
Trước hết, bạn nên kiểm tra định dạng của thông điệp bằng cách tiêu thụ một thông điệp duy nhất.
Sau đó, bạn có thể in và quan sát thông điệp để xác định cách xử lý dữ liệu tiếp theo.
Đây sẽ là nền tảng cho bài tập tiếp theo, nơi bạn sẽ đăng ký (subscribe) vào luồng dữ liệu và thu thập nhiều thông điệp.
Bài tập này là một phần của khóa học
Phân tích dữ liệu IoT bằng Python
Hướng dẫn bài tập
- Import thư viện MQTT
paho.mqtt.subscribevới bí danhsubscribe. - Lấy một thông điệp từ topic
"datacamp/iot/simple"và lưu vàomsg. - In topic và payload từ thông điệp, phân tách bằng dấu phẩy.
Bài tập tương tác thực hành trực tiếp
Hãy thử làm bài tập này bằng cách hoàn thành đoạn mã mẫu này.
# Import mqtt library
import ____ as ____
# Retrieve one message
msg = ____.____(____, hostname="mqtt.datacamp.com")
# Print topic and payload
print(f"{____}, {____}")