Googleコンテナエンジンの非同期タスクキュー

Question

Googleコンテナエンジン用のクラスタで、カスタムでスケーラブルなタスクキューを開発するための移植可能な方法を見つけようとしています。これはシナリオです。フロントエンドでノードjsインスタンスのユーザーの詳細を取得するシナリオです。これらの詳細はapiシステムに送信され、dbに連絡してユーザーの詳細を保存し、ウェルカムメールを送信する予定です。 私の問題は、私は同じメールエンドポイントのメソッドを使用してメールの送信リクエストを処理したくないので、私はkubernetesインフラストラクチャでそれをどのように処理する必要があるのか​​を別のプロセスで処理する必要がありますか？私がこれを行うと、すべてのサブスクリプションにアップデートが通知されますが、サブシステムのインスタンスが2つ実行されている場合は、変更がすべて観察され、メールが2回送信されます。これに関する考えやアイディアは高く評価されます。

Answer 1

これには2つの合理的な方法があります。

1：APIを使用して郵送イベントを受け取り、受け取った直後に郵送を非同期で処理するサービスがあります。 kubeサービスを使用すると、そのようなサービスの1つだけがヒットし、1つのメールは呼び出しサービスのための非ブロック的な方法で送信されますが、それには欠点があります。もし何かが失敗した場合、メールはまったく生成されないかもしれません。

2：おそらく（Kafka、Rabbitなど）いくつかのMQに行き、任意の数のメーリングサービスインスタンスがメッセージキューを消費し、メッセージを受け取ることができることを確認し、メッセージが返されない場合は処理に戻ります