2.2EventBridge によるイベント駆動

多数のサービスやアプリのイベントをルールで振り分けて処理につなぐのが Amazon EventBridge です。サーバーレスで疎結合なイベント駆動を実現します。

2.2.1イベントバスとルール

• イベントバス：イベントが流れる経路。AWS サービス・自作アプリ・SaaS（パートナー）のイベントを受ける。
• ルール：イベントパターン（JSON のマッチ条件）に合うイベントを選び、ターゲットへ送る。
• スケジュール：cron/rate 式で定期実行のトリガーにもなる（旧 CloudWatch Events）。
• ターゲット：Lambda・SQS・SNS・Step Functions など多数へ同時ルーティング。スキーマレジストリで型も管理。

EventBridge は「イベントのルーター」です。AWS の各サービスや自作アプリ、SaaS が発するイベントをイベントバスで受け、ルール（イベントパターン）で「どのイベントを・どのターゲットへ」流すかを宣言的に決めます。SNS との違いは、SNS が「トピックを購読する単純なファンアウト」なのに対し、EventBridge はイベントの中身（フィールド）でフィルタし、多様な AWS サービスへルーティングできる点。さらに cron/rate での定期実行も担い、これは旧 CloudWatch Events 由来です。「サービス間連携・内容によるルーティング・スケジュール」なら EventBridge、「シンプルに多数へ配る」なら SNS と使い分けます。

2.2.2大量のストリーミングデータ：Kinesis Data Streams

EventBridge や SNS/SQS が「個々のイベント/メッセージ」を扱うのに対し、秒間に大量のレコードが連続して流れ込むストリーミング（クリックストリーム、IoT テレメトリ、ログ）には Kinesis Data Streams が適します。Kinesis Data Streams は順序保証された耐久性の高いストリームで、データをシャードに分けて並列に取り込み、保持期間内なら同じデータを複数のコンシューマーが何度でも読み直せる（リプレイ）のが特徴です。複数の独立したアプリが同じストリームを別々に処理できるため、リアルタイム集計と保存用の処理を並走させられます。判断の勘所は「順序・リプレイ・大量並列が要るストリーミング＝Kinesis Data Streams」「1 件ずつ確実に処理して疎結合＝SQS」「単純なファンアウト通知＝SNS」です。変換せずそのまま S3/OpenSearch などへ配信したいだけなら、コード不要の Data Firehose を選びます。

2.2.3この節のまとめ

• EventBridge＝イベントパターンのルールで多様なターゲットへルーティング（内容ベース）
• スケジュール（cron）実行や AWS サービス連携に強い。単純な一斉配信は SNS