Kubernetes中Python Pod连接RabbitMQ触发pika.exceptions.AMQPConnectionError

下面是针对Kubernetes环境中Python Pod连接RabbitMQ失败的常见排查方向：

• 内部服务地址误用
  别用Ingress的外部域名来做内部Pod间通信，Python代码里应该用RabbitMQ Service的内部域名（比如rabbitmq-service:5672），Service名称和端口要对应上——AMQP默认端口是5672，不是UI的15672端口。

• 认证与权限配置不全
  确认代码里的用户名、密码完全匹配RabbitMQ里创建的账号，同时要检查该用户对/虚拟主机的权限：必须勾选配置、写入、读取三项，仅"访问"权限不足以创建队列。

• 网络策略拦截
  如果集群里配置了NetworkPolicy，要确认规则允许Python Pod所在Namespace访问RabbitMQ Service所在Namespace的5672端口，否则会被拦截。

• RabbitMQ服务状态异常
  即使UI能访问，AMQP服务可能没正常启动。执行kubectl logs <rabbitmq-pod-name>查看Pod日志，检查5672端口是否正常监听，或者是否达到连接上限。

• 依赖版本兼容性问题
  不同版本的pika和RabbitMQ可能存在兼容性问题。比如RabbitMQ 3.8+搭配pika 2.x时，可能需要手动设置心跳参数，示例：

  parameters = pika.ConnectionParameters(
      host='rabbitmq-service',
      port=5672,
      credentials=pika.PlainCredentials('user', 'password'),
      heartbeat=600,
      blocked_connection_timeout=300
  )
  

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