如果我有一个函数定义如下:如何动态地添加/删除定期任务,芹菜(celerybeat)
def add(x,y):
return x+y
有没有办法动态地添加该功能作为芹菜PeriodicTask并开始它在运行?我希望能够做到像(伪):
some_unique_task_id = celery.beat.schedule_task(add, run_every=crontab(minute="*/30"))
celery.beat.start(some_unique_task_id)
我也想停止或动态地删除该任务有类似的信息(伪):
celery.beat.remove_task(some_unique_task_id)
或
celery.beat.stop(some_unique_task_id)
仅供参考我不使用djcelery,它允许您通过django管理员管理定期任务。
你能否提一下代码来添加任务并删除?对不起,我没有得到。 – 2013-10-28 16:26:02
从2012年到2016年这个变化吗? – Tanay 2016-06-02 09:44:28