Sie können Erfolg und Fehler Rückrufe über den Link und LINK_ERR kwargs angeben, wenn Sie anrufen apply_async. Die Sellerie docs sind ein klares Beispiel: Ссылка
Ich verwende celery in meiner Anwendung, um periodische Aufgaben auszuführen. Lassen Sie uns ein einfaches Beispiel unten sehen
Wie Sie im obigen Beispiel sehen können, verwende ich celery , um eine asynchrone Task auszuführen, aber (da es eine Warteschlange ist) muss ich queue.fail(uid) im Ausnahmefall in do_stuff oder queue.ack(uid) ausführen. In dieser Situation wäre es sehr klar und nützlich, in beiden Fällen einen Rückruf von meiner Aufgabe zu erhalten - on_failure und on_success .
Ich habe einige gesehen Dokumentation , aber nie Praktiken der Verwendung von Callbacks mit apply_async gesehen. Ist das möglich?
Unterklasse die Klasse Task und überladen Sie die Funktionen on_success und on_failure:
%Vor%