无法通过WebSocket向AWS MQTT Broker发布消息的技术求助

从你的日志和代码来看，连接已经正常建立（{'session_present': False}确认是新会话连接成功），Publish操作也返回了Packet ID，但消息没出现在AWS控制台的测试订阅里，我帮你梳理几个高概率的排查方向：

1. 先确认IoT Core的权限配置 #

虽然连接成功了，但发布消息需要单独的iot:Publish权限，这点很容易被忽略：

• 检查你使用的IAM凭证（accessKey/secretKey对应的角色/用户）是否包含针对目标主题的权限策略，示例策略如下：

  {
      "Version": "2012-10-17",
      "Statement": [
          {
              "Effect": "Allow",
              "Action": "iot:Publish",
              "Resource": "arn:aws:iot:<你的区域ID>:<你的AWS账号ID>:topic/${你的主题名}"
          }
      ]
  }
  

• 注意替换策略里的区域、账号ID和主题名，确保覆盖你代码里的TOPIC和test/po两个主题。

2. 验证主题名称的完全匹配 #

MQTT主题是大小写敏感的，比如Test/PO和test/po是两个完全不同的主题：

• 检查AWS控制台测试订阅的主题和代码里发布的主题是否完全一致，包括大小写、斜杠位置；
• 可以临时用通配符#订阅所有主题，测试是否能收到消息，排除主题名称不匹配的问题。

3. 查看Publish Future的实际执行结果 #

你的代码只打印了Future的状态，但没有等待它完成，异步操作可能存在隐藏错误：
修改Publish部分的代码，等待Future结果并捕获异常：

future, packet_id = mqtt_connection.publish(topic=TOPIC, payload=json.dumps(message), qos=mqtt.QoS.AT_LEAST_ONCE)
try:
    publish_result = future.result()
    print(f"Publish for packet {packet_id} succeeded: {publish_result}")
except Exception as e:
    print(f"Publish for packet {packet_id} failed: {str(e)}")

这样能直接看到Publish操作是否真的成功，有没有权限或网络层面的隐藏问题。

4. 确认IoT端点和区域的正确性 #

• 检查auth_response_dictionary['user']['iotEndpoint']是否是AWS推荐的ATS格式端点，正确格式应为xxxxxx-ats.iot.<区域>.amazonaws.com；
• 确保代码里的region和你AWS控制台使用的区域完全一致（比如控制台用us-west-2，代码里不能写us-west-1）。

5. 检查事件循环的生命周期 #

如果你的程序在Publish后立即退出，异步事件循环可能还没来得及把消息发送出去：
在Publish后添加延迟或等待逻辑，确保消息完成发送：

import time

# 等待消息发送完成（根据网络情况调整时长）
time.sleep(3)

# 优雅关闭连接和事件循环
disconnect_future = mqtt_connection.disconnect()
disconnect_future.result()
event_loop_group.shutdown_gracefully()

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