Separation Sellerie Verbraucher und Produzent

Question

Ich möchte meine E-Mail-Service, dass ich schrieb, vollständig von meinem Kolben-Anwendung entkoppelt werden. Ich benutze Sellerie mit Rabbitmq. Ich frage mich also, ob ich Sellerie so konfigurieren kann, dass ich in einem Projekt die Flask-Anwendung habe, die die Nachricht an die Warteschlange (Produzent) sendet. Und in einem anderen Projekt lasse ich die Sellerie-Instanz laufen, die auf die Nachricht hört und die Aufgabe ausführt (Consumer). Ich bin immer noch verwirrt, wie die Kommunikation genau funktioniert? Setze ich die API (die die E-Mail sendet) in meine Flaschenapplikation ODER das Sellerie-Projekt? Letztendlich würde ich gerne die Flask-Anwendung und die Sellerie-Instanz in verschiedenen EC2-Instanzen haben - wobei rabbitmq als Nachrichtenvermittler fungiert.

Danke für Ihre Hilfe!

Answer 1

Sie können die Funktion send_task von Sellery verwenden, um die Aufgabe über RabbitMQ mithilfe des Aufgabennamens an den Mitarbeiter zu senden. Sie müssen noch um das Modul importieren, die Sie die Sellerie App haben:

Wenn die Aufgabe nicht im aktuellen Prozess registrieren Sie send_task() verwenden, anstatt die Aufgabe beim Namen zu nennen.

Beispiel:

from yourmodule.yourapp import celery 
celery.send_task("yourtasksmodule.yourtask", args=["Hello World"])