-
4 votesanswersviews
python芹菜 - 如何在运行时向工作者添加CELERYBEAT_SCHEDULE任务?
我创建了一个芹菜 Worker ,他们有一个celerybeat计划任务,以5秒的时间间隔运行 . 我想知道如何在不停止的情况下动态地向芹菜 Worker 添加另一个节拍任务 . 例 app.conf.update( CELERY_TASK_RESULT_EXPIRES=3600, CELERY_TIMEZONE = 'UTC', CELERYBEAT_SCHEDULE = { ... -
4 votesanswersviews
检查Celery中计划的定期任务的下一个运行时间(使用Django)
*使用芹菜3.1.25因为django-celery-beat 1.0.1存在调度周期性任务的问题 . 最近我遇到了celerybeat的一个问题,调度程序显示一天或更长间隔的周期性任务似乎是'forgotten' . 如果我将间隔更改为 every 5 seconds ,则任务正常执行(每5秒)并且 last_run_at 属性会更新 . 这意味着celerybeat在一定程度上响应了调度程序,... -
3 votesanswersviews
特定于队列的Celery事件
我有两个Django项目,每个项目都有一个Celery应用程序: - fooproj.celery_app - barproj.celery_app 每个应用程序都运行自己的Celery工作者: celery worker -A fooproj.celery_app -l info -E -Q foo_queue celery worker -A barproj.celery_app -l in...