Celery试图连接到错误的经纪人

Question

我有芹菜配置

BROKER_URL = 'redis://127.0.0.1:6379'
CELERY_RESULT_BACKEND = 'redis://127.0.0.1:6379'

然而每当我运行celeryd时,我都会收到此错误

consumer: Cannot connect to amqp://guest@127.0.0.1:5672//: [Errno 111] Connection refused. Trying again in 2.00 seconds...

为什么它没有连接到我设置的redis代理,运行btw？

Answer 1

导入你的芹菜并添加你的经纪人:

celery = Celery('task', broker='redis://127.0.0.1:6379')
celery.config_from_object(celeryconfig)