考虑一下这个bash会话:
$ export DJANGO_SETTINGS_MODULE=web.settings
$ celery status -b redis://redis.businessoptics.dev:6379/1 -t 10
Error: No nodes replied within time constraint.
$ celery status -b redis://redis.businessoptics.dev:6379/1 -t 10 -A scaffold.tasks.celery_app
celery@worker.9e2c39a1c42c: OK
为什么我需要-A
选项?据我所知,芹菜应该能够在redis上检测到必要的元数据。
类似地,如果我运行celery flower -b <redis url>
,它会显示它成功地连接到redis,但不会显示任何真正的工作者/任务/队列,并显示几个类似'stats' inspect method failed
的消息。同样,添加-A
会使其工作。
我想在一个最小的独立Docker容器中运行flower,这个容器不包含我的任何代码或它的依赖项。像这次这样的几次回购都提供了这种东西。那么我该怎么做呢?关联回购提供了许多选项,但没有办法指定-A
选项,这表明它没有必要。
我是芹菜的初学者,所以我可能错过了一些愚蠢的东西。我该怎么办?
scaffold.tasks.celery_app
模块简单地如下所示:
from celery import Celery
from django.conf import settings
app = Celery()
app.config_from_object(settings)
以下是Django中涉及芹菜的设置:
{'BROKER_HEARTBEAT': 0,
'BROKER_TRANSPORT_OPTIONS': {'fanout_patterns': True,
'fanout_prefix': True,
'visibility_timeout': 172800},
'BROKER_URL': 'redis://redis.businessoptics.dev:6379/1',
'CELERYBEAT_SCHEDULE': {'journey-heartbeat': {'args': (),
'schedule': <crontab: * * * * * (m/h/d/dM/MY)>,
'task': 'kms.data.journey.tasks.heartbeat'}},
'CELERYD_CONCURRENCY': 1,
'CELERYD_HIJACK_ROOT_LOGGER': False,
'CELERYD_LOG_COLOR': False,
'CELERYD_MAX_TASKS_PER_CHILD': 1,
'CELERYD_PREFETCH_MULTIPLIER': 1,
'CELERY_ACCEPT_CONTENT': ['pickle'],
'CELERY_ACKS_LATE': True,
'CELERY_DEFAULT_EXCHANGE': 'default',
'CELERY_DEFAULT_EXCHANGE_TYPE': 'direct',
'CELERY_DEFAULT_QUEUE': 'default',
'CELERY_DEFAULT_ROUTING_KEY': 'default',
'CELERY_IGNORE_RESULT': False,
'CELERY_IMPORTS': ['kms.knowledge.query.tasks2',
# names of several more modules...
],
'CELERY_QUEUES': [<unbound Queue tablestore -> <unbound Exchange default(direct)> -> kms.data.table_store.tasks.#>,
# several more similar-looking Queues...
<unbound Queue default -> <unbound Exchange default(direct)> -> default>],
'CELERY_REDIRECT_STDOUTS': False,
'CELERY_RESULT_BACKEND': 'database',
'CELERY_RESULT_DBURI': 'mysql://businessoptics:businessoptics@mysql.businessoptics.dev:3306/product',
'CELERY_RESULT_DB_SHORT_LIVED_SESSIONS': True,
'CELERY_ROUTES': ['scaffold.tasks.routers.TaskNameRouter'],
'CELERY_SEND_EVENTS': True,
'CELERY_SEND_TASK_ERROR_EMAILS': False,
'CELERY_SEND_TASK_SENT_EVENT': True,
'CELERY_STORE_ERRORS_EVEN_IF_IGNORED': True,
'CELERY_TASKNAME_ROUTES': [('tablestore', 'kms.data.table_store.tasks.#'),
# bunch of routes...
],
'CELERY_TASK_RESULT_EXPIRES': None,
'CELERY_TIMEZONE': 'UTC',
'CELERY_TRACK_STARTED': True,
'CELERY_WORKER_DIRECT': True
}
以下是相关版本:
celery==3.1.19
Django==1.8
django-celery==3.1.0
redis==2.10.3
-A选项是一个传递带有相关配置的芹菜实例的选项,包括包含任务的包。
要使用所有功能,花需要像工人一样进行配置,这意味着要知道你的芹菜任务所在的包,并了解它们。
将所需的python-lib添加到docker容器中应该没有那么难,例如,您可以通过以下方式将配置行CELERY_IMPORTS添加到该文件中:
CELERY_IMPORTS = os.getenv('CELERY_IMPORTS ', 'default.package')
更新
正如芹菜创建者@asksol在评论中指出的那样,这里有一个更详细的解释,解释你为什么需要-a选项:
Flower也是一个消息消费者,因此将有助于恢复未回复的消息。由于您已经定义了自定义可见性,启动flower unconfigured意味着它将使用默认的可见性超时,因此将比您的工作人员更快地重新传递未激活的消息。始终使用-A,以便工作人员、花和客户端配置同步