0

我有一个集成了 celery 的 heroku 的 django 项目。我已经通过 heroku 获得了 rabbitmq 插件，并在本地测试了我的任务以取得成功。我遇到的问题是将我的远程服务器连接到rabbitmq/cloudamqp。

我相信我使用的凭据是问题的罪魁祸首，但我不确定我哪里出错了。我正在使用通过 cloudamqp 仪表板提供给我的凭据。这包括：

AMQP URL
User & Vhost
Password

在我的 settings.py 中，我有：

CELERY_BROKER_URL= "amqp://{User}:{Password}@{AMQP URL}:5672/"

我尝试了多种其他形式，结果相似。最新的错误输出是：

amqp.exceptions.AccessRefused: (0, 0): (403) ACCESS_REFUSED - Login was refused using authentication mechanism AMQPLAIN. For details see the broker logfile.

我是否使用了正确的凭据？我是否需要通过命令行而不是管理仪表板创建 rabbitmq 用户？

4

1 回答 1

0

似乎 AMQP URL 包含所有详细信息（这是用于服务 cloudamqp）。

CELERY_BROKER_URL= "{AMQP URL}"
于 2020-04-16T05:40:20.563 回答