Tag: celerybeat

如何dynamic添加/删除周期性任务到芹菜（celerybeat）

如果我有一个函数定义如下： def add(x,y): return x+y 有没有办法dynamic地添加这个函数作为芹菜PeriodicTask并在运行时启动它？ 我想能够做一些像（伪代码）： some_unique_task_id = celery.beat.schedule_task(add, run_every=crontab(minute="*/30")) celery.beat.start(some_unique_task_id) 我也想用（伪代码）之类的东西来dynamic地停止或删除这个任务： celery.beat.remove_task(some_unique_task_id) 要么 celery.beat.stop(some_unique_task_id) 仅供参考我不使用djcelery，它允许您通过djangopipe理员pipe理定期任务。