如果我有一个定义如下的函数:
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管理员管理定期任务.