用于烧瓶应用的芹菜配置

Question

我已将芹菜配置为在dev box上为Flask应用程序运行异步作业，如下所示：

配置。py:

class CeleryConfig(object):
   CELERY_BROKER_URL = 'redis://localhost:6379/0'
   CELERY_RESULT_BACKEND = 'redis://localhost:6379/0'
CELERY_CONFIG = CeleryConfig

管理py:

celery_app = celery.Celery(config_source=app.config.get('CELERY_CONFIG'))

def run_celery():
    appl = celery.current_app._get_current_object()
    celery_worker = celery_worker.worker(app=appl)
    options = {
        'broker': config.get('CELERY_CONFIG').CELERY_BROKER_URL,
        'traceback': True,
    }
    celery_worker.run(**options)

在启动应用程序之前，我先启动redis：

./redis-server --daemonize yes

然后，当我运行应用程序（run_芹菜）时，会显示以下芹菜配置：

<>** ---------- .

以及以下重复出现的错误：

错误/主进程消费者：无法连接到amqp://guest:**@127.0.0.1:5672//：[Errno 111]连接拒绝。

我不知道为什么传输层使用RabbitMQ，为什么我不能启动芹菜。

Answer 1

这是因为参数是BROKER\u URL，而不是cellery\u BROKER\u URL。以下是可能设置的完整列表：http://docs.celeryproject.org/en/latest/userguide/configuration.html#new-小写设置

注意：该表是Celery 4.0中新小写设置的转换表，但如上所述：“Celery仍然能够读取旧的配置文件，所以不急于移动到新的设置格式”