使用Python Pika与RabbitMQ实现同步调用问题求助

针对你遇到的问题，结合AWS Lambda的场景，这里列出几个直接的排查点和解决办法：

1. 检查消息状态 #

如果之前用basic_consume测试时开启了auto_ack=False但未手动确认消息，队列里的消息会处于**Unacked（未确认）**状态。这类消息不会被basic_get获取，直到它们被重新入队（比如消费者断开连接）。

你可以通过RabbitMQ管理控制台查看队列的消息状态，确认是否有Unacked消息堆积。如果有，要么手动触发消息重新入队，要么确保测试时正确执行ack操作。

2. 显式声明队列 #

虽然basic_consume能正常识别队列，但basic_get在短连接场景（如Lambda）下，建议显式声明队列以确保连接能正确定位到目标队列：

# 显式声明队列，参数需和队列实际配置匹配
channel.queue_declare(queue=queue_name, durable=True, exclusive=False, auto_delete=False)

注：durable、exclusive等参数要和你创建队列时的配置保持一致。

3. 修正代码拼写错误 #

你的代码中basic_ack的参数存在拼写错误：method.deliverty_tag应改为method.delivery_tag（缺少字母e）。这个错误会导致拿到消息后无法正确确认，可能引发后续消息阻塞。

修正后的代码片段：

method, properties, body = channel.basic_get(queue_name)
if method:
    print(method, properties, body)
    channel.basic_ack(method.delivery_tag)  # 修正拼写错误
else:
    print('No message returned')

4. 明确basic_get参数 #

调用basic_get时显式指定auto_ack=False（尽管默认值就是这个），避免因参数默认值变更导致的问题：

method, properties, body = channel.basic_get(queue=queue_name, auto_ack=False)

5. Lambda场景额外注意事项 #

• Lambda执行环境短暂，每次调用都要重新初始化连接和通道，不要依赖容器复用的旧连接（容易失效）。
• 确保Lambda网络配置能正常访问RabbitMQ实例（如VPC peering、安全组开放对应端口）——不过你用basic_consume能正常工作，这一点大概率没问题。

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