Amazon EventBridge Pipes

Amazon EventBridge Pipes はソースをターゲットに接続します。パイプは、サポートされているソースとターゲット の統合を目的として point-to-pointおり、高度な変換とエンリッチメント をサポートしています。イベント駆動型アーキテクチャを開発する際に専門知識や統合コードが不要になり、会社のアプリケーション全体で一貫性が保持されます。パイプをセットアップするには、ソースを選択し、オプションのフィルタリングを追加し、オプションのエンリッチメントを定義し、イベントデータのターゲットを選択します。

注記

イベントバスを使用してイベントをルーティングすることもできます。イベントバスは、イベント駆動型サービス間のイベントのルーティングに適しています many-to-many。詳細については、「Amazon のイベントバス EventBridge」を参照してください。

EventBridge Pipes の仕組み

大まかに言うと、 EventBridge パイプの仕組みは次のとおりです。

1. アカウントにパイプを作成します。これには、以下が含まれます。

   • サポートされているイベントソースのうち、パイプにイベントを受信させたいもののいずれかを指定します。

   • オプションで、ソースから受信したイベントのサブセットだけをパイプが処理するようにフィルターを設定します。

   • オプションで、ターゲットに送信する前にイベントデータを拡張するエンリッチメントステップを設定します。

   • サポートされているターゲットのうち、パイプにイベントを送信させたいもののいずれかを指定します。

2. イベントソースはパイプへのイベントの送信を開始し、パイプはイベントを処理してからターゲットに送信します。

   • フィルターを設定した場合、パイプはイベントを評価し、そのフィルターに一致する場合にのみターゲットに送信します。

     フィルターに一致するイベントに対してのみ課金されます。

   • エンリッチメントを設定した場合、パイプはターゲットに送信する前にイベントに対してエンリッチメントを実行します。

     イベントがバッチ処理される場合、エンリッチメントはバッチ内のイベントの順序を維持します。

例えば、パイプを使って e コマースシステムを作ることができます。配送先住所などの顧客情報APIを含む があるとします。

1. パイプは以下を使用して作成できます。

   • Amazon SQS注文がイベントソースとしてメッセージキューを受信しました。

   • エンリッチメントとしての EventBridge APIデスティネーション

   • ターゲットとしての AWS Step Functions ステートマシン

2. 次に、Amazon SQS注文受信メッセージがキューに表示されると、パイプに送信されます。

3. 次に、パイプはそのデータを宛先エンリッチメントに送信し EventBridge API、送信先エンリッチメントはその注文の顧客情報を返します。

4. 最後に、パイプはエンリッチされたデータを AWS Step Functions ステートマシンに送信し、ステートマシンは注文を処理します。