Amazon EventBridge パイプは、イベントプロデューサーとコンシューマ間のポイントツーポイント統合を、オプションのトランスフォーム、フィルター、エンリッチステップで作成することができます。EventBridge Pipes は、イベント駆動型アプリケーションを構築する際に必要な統合コードの記述とメンテナンスの量を削減します。
仕組み
図は、Amazon EventBridge Pipes の仕組みを示しています。
最初のステップは「ソース」のタイトルで、「サポートされている AWS サービスからイベントを取り出す」と書かれています。 最初の図は、以下のような Amazon のソースのリストです。Amazon SQS、Amazon Kinesis Data Streams、Amazon DynamoDB、Amazon MSK、および Amazon MQ を含む Amazon ソースのリストです。
次のステップは、「Amazon EventBridge Pipes」というタイトルで、「あなたのイベントをフィルター、エンリッチ、トランスフォーム」と書かれています。
イラストは、EventBridge のロゴです。
次のステップは「フィルター」というタイトルで、「残すべきイベントを選択する」と書かれています。 イラストは漏斗です。
次のステップは、「エンリッチとトランスフォーム」というタイトルで、「再構築、修正、追加データのアカウントへの取り込み」と書かれています。 図は、AWS Lambda、AWS Step Functions、Amazon API Gateway、Amazon EventBridge API Destinations などの Amazon サービスの一覧です。
最後のステップは、「ターゲット」というタイトルで、「14 以上の AWS サービスのうちの 1 つにイベントを送信する」と書かれています。 最後の図は、以下のような AWS のサービス一覧です。Amazon EventBridge、Amazon Kinesis Data Streams、AWS Step Functions、Amazon API Gateway、Amazon SQS などです。
ユースケース
特徴
イベントのフィルタリング
アプリケーションが必要なイベントのみを処理するようにし、イベントのサブセットのみを使用するようにします。
イベントをバッチ
ソースからイベントを取得し、ターゲットに一括配信することで、統合をより効率的に行うことができます。
イベントを順序整理
イベントの順序が重要なアプリケーションに対応するため、順序の保証を提供します。
高い同時実行性
高い同時実行性をサポートし、大量のイベントを迅速に処理することができます。
高度なエンリッチメント
AWS Lambda、AWS Step Functions、API Gateway、または API Destinations を使用したサードパーティ API への API コールを使って、エンリッチメント機能を提供します。