MQTT 单条消息
请设想以下场景: 您拿到了一个 MQTT Broker 地址和一个主题名,需要编写代码来存储数据流的内容。
首先,请通过消费一条消息来确认消息的格式。
然后打印并检查这条消息,以确定后续应如何处理数据。
这将作为下一练习的基础,我们将订阅数据流并收集多条消息。
本练习是课程的一部分
用 Python 分析 IoT 数据
练习说明
- 导入 MQTT 库
paho.mqtt.subscribe,并命名为subscribe。 - 从主题
"datacamp/iot/simple"中获取 1 条消息,并将结果保存为msg。 - 打印该消息的主题与负载,中间用逗号分隔。
交互式实操练习
通过完成这段示例代码来试试这个练习。
# Import mqtt library
import ____ as ____
# Retrieve one message
msg = ____.____(____, hostname="mqtt.datacamp.com")
# Print topic and payload
print(f"{____}, {____}")