Celery无法连接RabbitMQ：密码含特殊字符不修改密码如何解决

你判断的问题原因正确：密码中的@和#属于URL保留字符，@会被解析为URL中认证信息和主机地址的分隔符，#会被解析为URL片段标识符的起始，导致AMQP连接URL结构被错误拆分，无法指向正确的RabbitMQ服务地址和vhost。无需修改原密码，可通过以下三种方案解决：

方案1：手动编码特殊字符 #

将密码中的@替换为%40，#替换为%23即可正常解析，修改后的初始化代码如下：

app = Celery('proj',
             broker=f'amqp://test:test%4012%234@localhost/test_vhost')

方案2：代码自动编码（兼容性更强） #

使用Python标准库的URL编码工具自动处理密码，避免遗漏其他特殊字符，无需手动查询编码值：

from urllib.parse import quote
from celery import Celery

# 原始密码无需任何修改
raw_password = "test@12#4"
encoded_password = quote(raw_password)
app = Celery('proj',
             broker=f'amqp://test:{encoded_password}@localhost/test_vhost')

方案3：拆分配置项（完全规避URL解析问题） #

不使用拼接URL的方式配置broker，单独设置各个连接参数，不需要处理任何编码逻辑：

from celery import Celery

app = Celery('proj')
app.conf.update(
    broker_url = "amqp://localhost:5672",
    broker_user = "test",
    broker_password = "test@12#4",
    broker_vhost = "test_vhost"
)

修改配置后重新执行celery -A proj worker -l info即可正常连接RabbitMQ。

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