Immer task_id innerhalb einer Sellerie Aufgabe

Dies ist wahrscheinlich eine dumme Frage aber die hat mich ratlos aus einem Rubinroten hintergrund.

Ich habe ein Objekt, das so aussieht, wenn ich versuche, es zu drucken.

print celery.AsyncResult.task_id
>>><property object at 0x10c383838>

Ich hatte erwartet, den tatsächlichen Wert der task_id-Eigenschaft gedruckt sehen. Wie bekomme ich den tatsächlichen Wert?

UPDATE 1

@celery.task
def scan(host):
    print celery.AsyncResult.task_id
    cmd = 'ps -ef'
    cm = shlex.split(cmd)
    scan = subprocess.check_output(cm)
    return scan

Beste Grüße.

Erstellen Sie eine Instanz der Klasse. propertys sind Deskriptoren werden verwendet, um Attribut-wie der Zugriff auf getter/setter-Methoden, aber Sie funktionieren auf der Instanz-Ebene. Wenn der Zugriff von der Klasse erhalten Sie einfach den property wrapper.
solltest du eigentlich post dies als eine Antwort 🙂
Aus dem Brief-Gehäuse und Ausgang-es sieht aus wie celery.AsyncResult muss der name der Klasse, nicht einer Instanz von einer, und task_id ist eine Eigenschaft, Attribut der Klasse-das ist was Bakuriu ist zu sagen, dass ich glaube.

InformationsquelleAutor user1513388 | 2013-09-18

15

Kurze Geschichte, Funktion within scan verwenden scan.request.id.

Sehen http://docs.celeryproject.org/en/latest/userguide/tasks.html?highlight=request#task-request-info
- Ja, ich denke, ich habe es ausprobiert, aber es hat nicht funktioniert im Kontext der Arbeiter. Ich werde es wieder versuchen, aber!
- Welche version von Sellerie verwenden Sie? Für ältere version (ich denke, bevor 2.2) es gab einen anderen Weg, es zu tun mit keyword-Parameter.
- Ich bin mit 3.0.23 (Chiastic Slide)
- Hmm - Naja, ich bin geblasen! Es funktioniert jetzt! Danke Chris! So einfach wie das Scannen.Anfrage.id
- Wählen Sie bitte mir, wie die richtige Antwort?
- Für mich, mit celery.current_task.request.id innerhalb der Aufgabe gearbeitet
InformationsquelleAutor Chris Johnson
13

Zugriff auf die Eigenschaft aus der Klasse, während task_id ist eine Eigenschaft von Instanzen von AsyncResult.

Erhalten Sie den Wert task_id müssen Sie zunächst erstellen Sie eine Instanz der Klasse, danach Zugriff auf async_result_instance.task_id werden Sie wieder die real-id.

In Ihrer aktualisierten code:
```
@celery.task
def scan(host):
    print celery.AsyncResult.task_id
    # ...
```
Hier haben Sie Zugriff auf die Klasse, wie ich schon erklärt. Was Sie wollen, ist eine Instanz des aktuell ausgeführten Aufgabe. Sie könnten Sellerie.current_task, um die aktuell ausgeführte task-Objekt:
```
@celery.task
def scan(host):
    print celery.current_task.task_id
```
Oder, wenn Sie daran interessiert sind, die eindeutige id verwenden, die Anfrage Attribut der dekorierten Funktion:
```
@celery.task
def scan(host):
    print scan.request.id
    cmd = 'ps -ef'
    cm = shlex.split(cmd)
    # IMPORTANT: Do *not* use "scan = ..."!
    result = subprocess.check_output(cm)
    return result
```
In diesem zweiten Fall tun nicht Verwendung jede lokale variable namens scan sonst wirst du ein UnboundLocalError.

(Code nicht getestet, da ich nicht celery installiert).

Den propertys sind Deskriptoren verwendet, um Attribut-wie der Zugriff auf getter/setter-Methoden, so dass Sie Zugriff auf Daten wie:
```
instance.attribute
instance.attribute = value
```
Aber wenn der code ausgeführt wird, der setter oder getter kontrollieren kann, was Los ist.

Überprüfen kann man das mit einem dummy-Klasse:
```
>>> class Dummy(object):
...     @property
...     def a(self):
...             print("called the getter!")
...             return 1
... 
>>> Dummy.a
<property object at 0x7fdae86978e8>
>>> Dummy().a
called the getter!
1
```
- Hmm..ich habe versucht dein Beispiel oben, und es macht Sinn. Jedoch im Rahmen der Sellerie worker funktioniert es nicht. Ich denke, weil Sie den Sellerie.AsyncResult-Klasse bereits erstellt wurde. Also ich glaube, ich muss so etwas wie "selbst"?
InformationsquelleAutor Bakuriu
11

Um Ihre Aufgaben noch "OO-like", könnte die bind argument um eine Referenz zu self:
```
@celery.task(bind=True)
def scan(self, host):
  print self.request.id
```
Bitte beachten Sie, dass self.request.id ist tatsächlich eine Instanz AsyncTask. Um die task-id als string, die Sie tun sollten self.request.id.__str__().

Vom Sellerie in der Dokumentation (nach dem Beispiel):

Den bind argument bedeutet, dass die Funktion einer "bestimmten Methode", so dass Sie den Zugriff auf Attribute und Methoden des Typs task-Instanz.

InformationsquelleAutor Victor

Schreibe einen Kommentar

Du musst angemeldet sein, um einen Kommentar abzugeben.