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.