python - 有没有可能在 Celery 中创建动态周期性任务的方法？

Question

我想从 celery 调度程序中添加和删除定期任务，但是我没有找到一种简单的方法来做到这一点。可能吗？

我找到了下一个问题，但我想知道是否有不使用 Django 的替代方案。 如何向 Celery (celerybeat) 动态添加/删除周期性任务

Answer 1

要从 celery 调度程序中删除任务，您可以使用

from celery.task.control import discard_all
discard_all()

您可以在此处查看有关如何将任务附加到调度程序的详细说明。