イベント駆動マイクロサービスを構築する

第5章. イベント駆動処理の基本

この作品はAIを使って翻訳されている。ご意見、ご感想をお待ちしている：[e-mail]

ほとんどのイベント駆動マイクロサービスは、最低限、同じ3つのステップを踏む：

1. 入力イベントストリームからイベントを消費する。

2. そのイベントを処理する。

3. 必要な出力イベントをプロデューサする。

また、同期リクエスト/レスポンス対話から入力イベントを生成するイベント駆動のマイクロサービスもある。この章では、イベントストリームからイベントを生成するマイクロサービスのみを取り上げる。

ストリームソースイベントドリブンマイクロサービスでは、マイクロサービスインスタンスはプロデューサークライアントとコンシューマークライアントを作成し、必要であればコンシューマグループに登録する。マイクロサービスはコンシューマークライアントに新しいイベントをポーリングするループを開始し、入ってきたイベントを処理し、必要な出力イベントを発行する。このワークフローを以下の擬似コードに示す。(もちろん、言語、ストリーム処理フレームワーク、イベントブローカーの選択、その他の技術的要因によって実装は異なるだろう)

Consumer consumerClient = new consumerClient(consumerGroupName, ...);
Producer producerClient = new producerClient(...);

while(true) {
    InputEvent event = consumerClient.pollOneEvent(inputEventStream);
    OutputEvent output = processEvent(event);
    producerClient.produceEventToStream(outputEventStream, output);

    //At-least-once processing.
    consumerClient.commitOffsets();
}

特に注目すべきは、processEvent 関数である。主にビジネスロジックの適用と、イベントがある場合はどのイベントを発行するかである。この処理関数は、マイクロサービスの処理トポロジーへのエントリポイントとして考えるのがベストである。ここから、データ駆動パターンが境界づけられたコンテキストのビジネスニーズに合わせてデータを変換・処理する。

ステートレス・トポロジーを構成する

マイクロサービスのトポロジーを構築するには、コンシューマ・インプットに到着したイベントにレスポンスしてコードが実行されるように、イベント・ドリブンで考える必要がある。マイクロサービスのトポロジーは、基本的にイベントに対して実行する演算子のシーケンスである。マイクロサービスに必要なビジネスロジックを実行するために必要なフィルタリング、ルーター、変換、マテリアライゼーション、集約、その他の関数を選択する必要がある。関数型プログラミングやビッグデータのマップ・リダクション・スタイルのフレームワークに慣れ親しんでいる人たちは、ここでかなりくつろげるかもしれない。他の人にとっては、これは少し新しい概念かもしれない。

図5-1のトポロジーを考えてみよう。イベントは一度に1つずつコンシューマされ、ステージ1と2の変換に従って処理される。

図5-1. 単純なイベント処理トポロジー

キーがA とC のイベントは両方ともトポロジー全体を横断する。それらは両方とも ...