2016-07-08 19 views
0
from celery import Celery 

app = Celery('tasks', backend='amqp://[email protected]', broker='amqp://[email protected]//') 


@app.task() 
def add(x, y): 
    return x + y 

Ich bin erfolgreich in der Lage, Sellerie Aufgaben zu senden, aber wenn ich versuche, die Ergebnisse der Aufgabe zu erhalten, sendet es sie nicht zurück. Ich denke, das wird dadurch verursacht, dass die Backend-IP auf eine externe IP eingestellt ist und Sellerie das nicht respektiert.Warum zeigt ein Sellerie-Backend nicht auf eine IP, die nicht lokal arbeitet?

- ** ---------- .> transport: amqp://guest:**@192.168.99.100:5672// 
- ** ---------- .> results:  amqp:// 

Oben ist der Ausgang, wenn ich ‚Sellerie -A workers.tasks Arbeiter --loglevel = debug‘ laufen

+0

Haben Sie versucht, mit einem anderen Konto, anders als Gast? – cantSleepNow

+0

@cantSleepNow Ja habe ich aber der Threading-Switch scheint die einzige Lösung zu sein. –

Antwort

0

Ich weiß nicht genau, warum das es funktionierte aber

tat

Führen Sie das Befehl mit der --pool = Fäden/Solo

Sellerie -A proj.tasks Arbeiter -l info wechseln --pool = Fäden -n w1