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