Separazione del consumatore e produttore di sedano

Question

Desidero che il mio servizio di posta elettronica che ho scritto sia completamente disaccoppiato dalla mia applicazione di flask. Sto usando il sedano con rabbitmq. Quindi mi chiedo se c'è un modo per configurare il sedano così che in un progetto ho l'applicazione Flask che invia il messaggio alla coda (produttore). E in un altro progetto ho l'istanza di Celery in esecuzione che ascolta il messaggio ed esegue l'attività (utente). Sono ancora confuso da come funziona esattamente la comunicazione? Inserisco l'API (che invia l'e-mail) nella mia applicazione di flask O nel progetto di sedano? In definitiva mi piacerebbe avere l'applicazione Flask e l'istanza di Celery in diverse istanze EC2 - con rabbitmq che funge da broker dei messaggi.

Grazie per il vostro aiuto!

Answer 1

È possibile utilizzare la funzione send_task di Celery per inviare l'attività tramite RabbitMQ all'operatore utilizzando il nome dell'attività. Hai ancora bisogno di importare il modulo che si ha l'applicazione sedano in:

Se l'operazione non è registrato nel processo in corso è possibile utilizzare send_task() per chiamare il compito per nome invece.

Esempio:

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