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

Question

我已经创建了一个芹菜工作者和一个单一的celerybeat计划任务，它以5秒的时间间隔运行。我想知道如何在不停止的情况下向芹菜工作人员动态添加另一个节拍任务。

例

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,) 
    } 
    } 
) 

与上面的配置，我能够成功运行与节拍模式芹菜工人。

现在我需要添加下面的节拍安排动态

'长期-2-秒'：{ '任务'： 'test_proj.tasks.test'， '日程'：timedelta（秒= 2）， 'ARGS'：（14）}，

需要帮助的本

由于

Answer 1

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