Celery无法连接Redis结果后端求助（Broker连接正常）

核心问题分析 #

从错误日志Connection closed by server以及Broker连接正常、结果后端连接失败的现象来看，大概率是结果后端URL格式错误或SSL配置缺失导致的，和凭证本身无关。

针对性解决方法 #

1. 修正结果后端URL的拼接逻辑 #

你的代码中手动拼接/0指定数据库的方式可能导致URL格式错误：

celery.conf.result_backend = f"{ResultBackend}/0"

如果你的UPSTASH_REDIS_URL本身已经包含数据库路径（比如redis://:<PASSWORD>@<HOST>:<PORT>/0），拼接后会变成redis://:<PASSWORD>@<HOST>:<PORT>/0/0，触发解析错误；如果原URL结尾带有斜杠，会生成redis://...//0这种无效格式（对应日志里的//:）。

修复方式：

• 直接在环境变量UPSTASH_REDIS_URL中指定数据库，比如设置为redis://:<PASSWORD>@<HOST>:<PORT>/0
• 代码中直接赋值，不再手动拼接：

  celery.conf.result_backend = ResultBackend
  

• 如果必须手动指定数据库，先确保原URL没有结尾斜杠：

  # 去掉原URL的结尾斜杠
  cleaned_result_backend = ResultBackend.rstrip('/')
  celery.conf.result_backend = f"{cleaned_result_backend}/0"
  

2. 强制启用SSL连接 #

Upstash（尤其是Heroku上的插件版本）默认要求SSL连接，但Celery的Redis结果后端默认可能未启用SSL，导致服务器主动关闭连接。

修复方式：

• 将结果后端URL的协议从redis://改为rediss://：

  celery.conf.result_backend = ResultBackend.replace("redis://", "rediss://")
  

• 或者通过Celery配置强制开启SSL：

  celery.conf.redis_backend_use_ssl = {
      'ssl_cert_reqs': None  # 跳过证书验证（如果环境中无法获取根证书）
  }
  

3. 升级Redis客户端依赖 #

Celery 5.2.3对应的redis-py最低版本要求是3.5.3，但Upstash可能需要更高版本的客户端支持。执行以下命令升级：

pip install --upgrade redis>=4.5.0

4. 验证数据库权限 #

虽然你用Redis客户端测试连接成功，但仍需确认：

• Upstash实例是否允许使用指定的数据库（比如数据库0）
• 凭证是否拥有该数据库的读写权限

其他补充排查步骤 #

• 检查Celery日志的详细输出，确认是否有隐藏的SSL错误或协议不匹配信息
• 用redis-cli测试结果后端URL的连接：

  redis-cli -u rediss://:<PASSWORD>@<HOST>:<PORT>/0 ping
  

  如果返回PONG，说明URL本身有效，问题出在Celery的配置上

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