python芹菜 – 如何在运行时向工作者添加CELERYBEAT_SCHEDULE任务？

概述我创建了一个芹菜工人,他们有一个celerybeat计划任务,以5秒的时间间隔运行.我想知道如何在不停止的情况下动态地向芹菜工人添加另一个节拍任务. 例 app.conf.update( CELERY_TASK_RESULT_EXPIRES=3600, CELERY_TIMEZONE = 'UTC', CELERYBEAT_SCHEDULE = { 'long-run-5 我创建了一个芹菜工人,他们有一个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,)    }   })

通过上面的配置,我能够成功地以节拍模式运行芹菜工作者.

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

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

需要帮助

谢谢

解决方法 我一直在寻找同样问题的@R_301_6954@案.我很害怕你必须等待Celery ver.4.0.动态任务调度目前仅在开发版本中支持： http://docs.celeryproject.org/en/master/userguide/periodic-tasks.html#beat-entries 总结

以上是内存溢出为你收集整理的python芹菜 – 如何在运行时向工作者添加CELERYBEAT_SCHEDULE任务？全部内容，希望文章能够帮你解决python芹菜 – 如何在运行时向工作者添加CELERYBEAT_SCHEDULE任务？所遇到的程序开发问题。

如果觉得内存溢出网站内容还不错，欢迎将内存溢出网站推荐给程序员好友。