开始使用免费开始使用

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"{____}, {____}")
编辑并运行代码