Wie man Ergebniswarteschlange für Sellerie Aufgabe wählen?

Question

Hier ist meine Sellerie config:

BROKER_TRANSPORT='amqp', 
CELERY_RESULT_BACKEND='rpc://', 

I Aufgabe sende diese Art und Weise auszuführen:

result = my_function.apply_async(('arguments here',), queue='queue_123') 

Sellerie wie erwartet funktioniert, sehe ich diese Aufgaben in "queue_123".

Jetzt muss ich alle Ergebnisse der Ausführung in die Warteschlange "my_result_queue" bekommen. Wie kann ich es tun?

Sellery erstellt jetzt eine neue Warteschlange mit Namen wie "19b7013a-a077-3d2a-b60a-d57c51d5d30c" und fügt Ergebnisse hinzu. Ich muss dieses Verhalten beheben und Ergebnisse in die Warteschlange mit dem angegebenen Namen einfügen.

Ich brauche etwas wie folgt aus:

result = my_function.apply_async(('arguments here',), queue='queue_123', results_queue='my_result_queue') 

Answer 1

@app.task(reply_to='result_queue)