Webサービス+セロリ

Question

私は、着信Webサービス要求を処理するためにセロリを使用する予定。私はセロリが主に非同期タスクを処理するために使用されていることを理解しています。私はデザインに苦しんでいます

などの優先順位、レート制限、分散アーキテクチャ - しかし、セロリは私が好きで、私のプロジェクトでから利益を得ることができる機能をたくさん持っています。サブタスクと呼ばれるタスクを作成して開始するWebサービスを用意したいと思います。オリジナルのタスクはサブタスクの結果を必要とし、オリジナルのタスクが終了したらWebサービスを通じて結果をクライアントに返します。私はタスクを同期的に呼び出すことができますが、それは良い方法ではないことを知っています。

ありがとう、

Answer 1

スキャッタ/ギャザーは、マップ/リダクションジョブのように見えます。 MapReduceの部分が重要な場合、DiscoやHadoopのような専門的な枠組みで行きます。一度すべてのサブタスクが完了またはキャンセルされたユーザへの応答を発射できるように、そうでなければ、あなたは、完了信号のいくつかの種類を必要とします。たとえば、いくつのサブタスクがまだ終了していないかのカウンタ。ゼロにカウンターをもたらすサブタスクは、ユーザーに返信をプッシュし、円を閉じ、新しい返信タスクをプッシュすることができます。

は円形のリクエストパスのこの種の、例えば、Mongrel2で非同期Webフレームワークを見て。