我有一个将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用户吗?
似乎AMQP URL具有所有详细信息(这是针对服务cloudamqp的。)>
CELERY_BROKER_URL= "{AMQP URL}"