python celery - 如何在运行时向工作人员添加 CELERYBEAT_SCHEDULE 任务？

Question

我创建了一个 celery worker，它有一个以 5 秒时间间隔运行的单个 celerybeat 计划任务。如何在不停止 celery worker 的情况下动态添加另一个节拍任务？

例子

app.conf.update(
   CELERY_TASK_RESULT_EXPIRES=3600,
   CELERY_TIMEZONE = 'UTC',
   CELERYBEAT_SCHEDULE = {
    'long-run-5-secs': {
        'task': 'test_proj.tasks.test',
        'schedule': timedelta(seconds=5),
        'args': (16, )
    }
   }
)

通过上面的配置，我能够成功地以节拍模式运行celery worker。

现在我需要动态添加以下节拍时间表:

'long-run-2-secs': {
    'task': 'test_proj.tasks.test',
    'schedule': timedelta(seconds=2),
    'args': (14, ) },

谢谢

Answer 1

我一直在为同样的问题寻找解决方案。恐怕您将不得不等待 Celery ver.4.0。动态任务调度目前仅在开发版本中支持:http://docs.celeryproject.org/en/master/userguide/periodic-tasks.html#beat-entries