セロリの消費者と生産者を分ける

Question

私が書いた電子メールサービスを私のフラスコのアプリケーションから完全に切り離したい。私はrabbitmqでセロリを使用しています。だから、あるプロジェクトでキュー（プロデューサ）にメッセージを送信するFlaskアプリケーションがあるように、セロリを設定できる方法があるのだろうかと思います。そして別のプロジェクトでは、メッセージを聞いてタスク（消費者）を実行するセロリインスタンスを実行しています。コミュニケーションがどのようにうまくいくのか、私はまだ混乱していますか？私はフラスコのアプリケーションまたはセロリプロジェクトにAPI（電子メールを送信する）を入れますか？最終的に私はFlaskアプリケーションとCeleryインスタンスを異なるEC2インスタンスに入れたいと思っています - メッセージブローカーとして機能するrabbitmqを使用しています。

ありがとうございました！

Answer 1

Celeryのsend_task関数を使用すると、タスク名を使用してRabbitMQを介してRabbitMQを介して作業者にタスクを送信できます。タスクがあなたの代わりに名前でタスクを呼び出すために send_taskを（）を使用することができ、現在のプロセスに登録されていない場合は

：あなたはまだあなたがセロリのアプリを持っているモジュールをインポートする必要があります。

例：

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