Sellerie - Task-ID für aktuelle Aufgabe abrufen

Question

Wie kann ich den task_id-Wert für eine Aufgabe innerhalb der Aufgabe abrufen? Hier ist mein Code:

from celery.decorators import task 
from django.core.cache import cache 

@task 
def do_job(path): 
    "Performs an operation on a file" 

    # ... Code to perform the operation ... 

    cache.set(current_task_id, operation_results) 

Die Idee ist, dass, wenn ich eine neue Instanz der Aufgabe zu erstellen, ich habe die task_id aus dem Task-Objekt abzurufen. Ich benutze dann die Task-ID, um festzustellen, ob die Task abgeschlossen wurde. I nicht wollen die Aufgabe durch den Wert path verfolgen, weil die Datei "bereinigt" wird, nachdem die Aufgabe abgeschlossen ist, und möglicherweise nicht vorhanden ist oder nicht.

Im obigen Beispiel, wie würde ich den Wert current_task_id bekommen?

Answer 1

Sellerie legt einige Standardschlüsselwortargumente fest, wenn die Aufgabe sie akzeptiert. (Sie können sie entweder durch Verwendung ** kwargs akzeptieren, oder sie speziell Liste)

@task 
def do_job(path, task_id=None): 
    cache.set(task_id, operation_results) 

Die Liste der Standard-Schlüsselwort-Argumente ist hier dokumentiert: http://ask.github.com/celery/userguide/tasks.html#default-keyword-arguments

Answer 2

Da Sellerie 2.2.0 Informationen im Zusammenhang mit Die aktuell ausgeführte Aufgabe wird in task.request gespeichert (sie wird «der Kontext» genannt). So sollten Sie Aufgabe id aus diesem Zusammenhang bekommen (nicht von Keyword-Argumente, die veraltet sind):

@task 
def do_job(path): 
    cache.set(do_job.request.id, operation_results) 

Die Liste aller verfügbaren Felder hier dokumentiert ist: http://celery.readthedocs.org/en/latest/userguide/tasks.html?highlight=requestcontext#context

Answer 3

Ab Sellerie 3.1 können Sie verwenden Sie die bind Dekorateur Argument, und haben Zugriff auf die aktuelle Anforderung:

@task(bind=True) 
def do_job(self, path): 
    cache.set(self.request.id, operation_results)