Google Cloud IoT使用Python订阅主题但无法接收事件问题

看起来你已经能成功连接到Google Cloud的MQTT broker，但订阅后收不到事件，我帮你梳理几个最常见的排查方向：

1. 确认MQTT主题格式完全正确 #

Google Cloud IoT Core的MQTT主题有严格的格式要求，千万别写错：

• 订阅单台设备的事件，主题应为：/devices/{你的设备ID}/events
• 订阅所有设备的事件，主题是：/devices/#（注意#是MQTT通配符，必须放在主题末尾）
• 如果设备发布时指定了子主题（比如/devices/{device-id}/events/temperature），订阅时要对应写成/devices/{device-id}/events/#才能收到

先检查你代码里的订阅主题，是不是和设备实际发布的主题完全匹配？

2. 验证JWT认证与权限配置 #

Google Cloud IoT的MQTT连接必须用JWT令牌做身份验证，同时服务账号需要对应权限：

• 确保JWT是用设备关联的服务账号密钥生成的，有效期设置合理（建议不超过24小时）
• 检查IoT设备注册表的权限：你的服务账号需要拥有cloudiot.pubsubSubscriber权限，或者更宽泛的Cloud IoT Viewer/Cloud IoT Editor角色
• 代码里要正确设置用户名和密码：Google IoT要求用户名为unused，密码是生成的JWT，示例如下：

client.username_pw_set(username='unused', password=jwt_token)

3. 检查消息回调函数是否正确配置 #

如果没给MQTT客户端设置on_message回调，就算收到消息也不会有任何反馈。一定要加上类似这样的回调逻辑：

def on_message(client, userdata, msg):
    print(f"收到消息: 主题 {msg.topic}, 内容 {msg.payload.decode()}")

client.on_message = on_message

另外订阅时建议将QoS等级设为1（Google IoT支持QoS 0和1，QoS1可靠性更高）：

client.subscribe("/devices/#", qos=1)

4. 确保客户端保持消息循环 #

MQTT客户端需要持续运行消息循环才能处理入站消息，如果连接订阅后就结束代码，肯定收不到消息。代码最后要加上消息循环逻辑：

# 阻塞式循环（适合简单场景）
client.loop_forever()

# 或者非阻塞式循环（适合后台运行）
client.loop_start()
# 保持程序运行的逻辑
while True:
    time.sleep(1)

5. 确认设备确实在发布消息 #

最后别忽略设备端的问题：

• 登录Google Cloud Console的IoT Core界面，查看设备的「最近事件」，确认有没有消息被发送上来
• 用gcloud命令行工具订阅对应的Pub/Sub主题（IoT Core事件最终会流转到Pub/Sub），验证消息是否存在：

gcloud pubsub subscriptions pull --auto-ack {你的订阅ID}

如果Pub/Sub能收到消息，问题大概率在你的MQTT客户端代码；如果Pub/Sub也没收到，就要检查设备的发布逻辑了。

你可以先从主题格式和消息循环这两点入手排查，很多时候都是这两个环节出了小疏漏。

内容的提问来源于stack exchange，提问作者StuckForTooLong