我想创建具有不同配置的芹菜工人。
我使用以下命令创建工作线程:
celery worker -A proj -l info --config=celeryconfig2.py -Ofair -n worker2.%h
celery worker -A proj -l info --config=celeryconfig.py -Ofair -n worker.%h
但是,这会创建两个工作线程,并将 config 作为 celeryconfig.py。
我的项目结构如下:
scripts/
proj/
-- celery.py
-- celeryconfig.py
-- celeryconfig2.py
-- __init__.py
从命令行加载 celery 配置时,应提供配置模块名称而不是文件名。
因此,您必须从存在配置的文件夹中启动这样的工作线程。
celery worker -A proj -l info --config=celeryconfig
celery worker -A proj -l info --config=celeryconfig2
或者,您也可以给出模块路径,例如
celery worker -A proj -l info --config=foo.bar.celeryconfig
但不是这样的
celery worker -A proj -l info --config=celeryconfig.py
celery worker -A proj -l info --config=celeryconfig2.pt