Dynamisches Hinzufügen / Entfernen von periodischen Aufgaben zu Sellerie (Sellerie)

Wenn ich eine Funktion wie folgt definiert habe:

<code>def add(x,y):
  return x+y
</code>

Gibt es eine Möglichkeit, diese Funktion dynamisch als Sellerie-PeriodicTask hinzuzufügen und zur Laufzeit zu starten? Ich möchte in der Lage sein, etwas wie (Pseudocode) zu tun:

<code>some_unique_task_id = celery.beat.schedule_task(add, run_every=crontab(minute="*/30"))
celery.beat.start(some_unique_task_id)
</code>

Ich möchte diese Aufgabe auch mit so etwas wie (Pseudocode) stoppen oder dynamisch entfernen:

<code>celery.beat.remove_task(some_unique_task_id)
</code>

oder

<code>celery.beat.stop(some_unique_task_id)
</code>

Zu Ihrer Information, ich verwende kein djcelery, mit dem Sie regelmäßige Aufgaben über den django-Administrator verwalten können.

Antworten auf die Frage(4)

Ihre Antwort auf die Frage