サーバーレスイベントフィルタリング - EventBridge vs Azure Event Grid

イベント駆動アーキテクチャと EventBridge の位置づけ

イベント駆動アーキテクチャは、サービス間の疎結合を実現し、スケーラブルで保守性の高いシステムを構築するための設計パターンです。AWS EventBridge は 2019 年に CloudWatch Events の後継として登場し、200 以上の AWS サービスと 35 以上の SaaS パートナー (Zendesk、Datadog、PagerDuty など) からのイベントをネイティブに受信できるサーバーレスイベントバスです。Azure Event Grid も同様のイベントルーティングサービスですが、AWS サービスとの統合数で EventBridge が大きくリードしています。EventBridge の料金は、カスタムイベントとクロスアカウントイベントが 100 万件あたり 1.00 USD、AWS サービスからのデフォルトイベントは無料です。Azure Event Grid は操作あたり 0.60 USD/100 万件ですが、高度なフィルタリングを使用する場合は追加料金が発生します。EventBridge はイベントバスを複数作成でき、アプリケーションごと、チームごとにイベントの名前空間を分離できます。この分離により、大規模組織でのイベント管理が整理され、アクセス制御も IAM ポリシーでイベントバス単位で設定可能です。

この分野について体系的に学びたい方は、関連書籍 (Amazon) も参考になります。

高度なイベントフィルタリングパターン

EventBridge のイベントパターンマッチングは、JSON ベースのルールで柔軟なフィルタリングを実現します。完全一致、プレフィックスマッチ、サフィックスマッチ、数値比較 (greater-than、less-than、between)、IP アドレスマッチ、exists チェック、anything-but (否定マッチ) など、17 種類以上のフィルタリング演算子を提供します。たとえば、EC2 インスタンスの状態変更イベントのうち、特定のタグを持つインスタンスが terminated になった場合のみ Lambda を起動する、といった複合条件を 1 つのルールで記述できます。Azure Event Grid のフィルタリングは、subject のプレフィックス/サフィックスマッチ、イベントタイプのフィルタ、高度なフィルタリング (数値比較、文字列比較) をサポートしますが、EventBridge の anything-but (否定マッチ) や IP アドレスマッチに相当する機能がなく、複雑なフィルタリング条件では Lambda や Azure Functions で追加のフィルタリングロジックを実装する必要があります。EventBridge のコンテンツベースフィルタリングは、イベントの body 内の任意のフィールドに対してパターンマッチングを適用でき、ネストされた JSON 構造の深い階層にもアクセス可能です。

スキーマレジストリとイベントの発見性

EventBridge スキーマレジストリは、イベントバスを流れるイベントのスキーマを自動的に検出・登録する機能です。スキーマディスカバリーを有効にすると、EventBridge がイベントの構造を自動的に推論し、OpenAPI 3.0 形式のスキーマとして登録します。開発者はこのスキーマから Java、Python、TypeScript のコードバインディングを自動生成でき、型安全なイベント処理コードを迅速に実装できます。Azure Event Grid にはスキーマレジストリに相当する機能がなく、イベントスキーマの管理は開発者が手動で行う必要があります。EventBridge のスキーマレジストリは、バージョニングもサポートしており、スキーマの変更履歴を追跡できます。これにより、イベントプロデューサーがスキーマを変更した場合に、コンシューマー側への影響を事前に把握できます。スキーマレジストリの料金は、取り込まれたイベント 100 万件あたり 0.10 USD で、スキーマの保存自体は無料です。大規模なマイクロサービスアーキテクチャでは、数十のサービスが数百種類のイベントを発行するため、スキーマレジストリによるイベントカタログの自動構築は開発生産性に大きく貢献します。

アーカイブ & リプレイとイベントの耐久性

EventBridge のアーカイブ & リプレイ機能は、イベントバスを流れるイベントを自動的にアーカイブし、任意の期間のイベントを再生 (リプレイ) できる機能です。アーカイブの保持期間は無期限に設定でき、料金はアーカイブされたイベントデータ 1 GB あたり 0.023 USD/月です。リプレイ時は、開始時刻と終了時刻を指定して特定期間のイベントを再生でき、さらにイベントパターンでフィルタリングして特定のイベントのみを再生することも可能です。この機能は、障害復旧時のイベント再処理、新しいコンシューマーの追加時のバックフィル、イベント処理ロジックのデバッグなど、多くのユースケースで活用できます。Azure Event Grid にはアーカイブ & リプレイに相当するネイティブ機能がなく、同様の機能を実現するには Azure Event Hubs Capture や Azure Storage への手動保存と再送ロジックの実装が必要です。EventBridge はさらに、デッドレターキュー (DLQ) をターゲットごとに設定でき、配信に失敗したイベントを SQS キューに自動的に退避します。DLQ に退避されたイベントは、失敗原因の調査後に手動または自動で再処理できます。

EventBridge Pipes とイベント変換

EventBridge Pipes は 2022 年に追加された機能で、イベントソースからターゲットへのポイントツーポイント統合を、フィルタリング、エンリッチメント、変換のステップを含むパイプラインとして定義できます。ソースとして SQS、Kinesis Data Streams、DynamoDB Streams、Managed Streaming for Apache Kafka (MSK)、セルフマネージド Kafka をサポートし、ターゲットとして Lambda、Step Functions、API Gateway、EventBridge、SNS、SQS など 15 以上のサービスに接続できます。Pipes のエンリッチメントステップでは、Lambda 関数、Step Functions、API Gateway、API デスティネーションを呼び出してイベントデータを補完・変換できます。たとえば、DynamoDB Streams から受信した変更イベントに対して、Lambda でユーザー情報を付加してから SNS に通知する、といったパイプラインをコードなしで構築できます。Azure Event Grid にはこのようなパイプライン型の統合機能がなく、同様の処理を実現するには Azure Functions や Logic Apps で中間処理を実装する必要があります。Pipes の料金はリクエスト 100 万件あたり 0.40 USD で、Lambda を介さない分のコスト削減効果もあります。

さらに詳しく知りたい方は、関連書籍 (Amazon) で理解を深められます。

まとめ

AWS EventBridge は、200 以上の AWS サービスと 35 以上の SaaS パートナーとのネイティブ統合、17 種類以上のフィルタリング演算子、スキーマレジストリによるイベントカタログの自動構築、アーカイブ & リプレイによるイベントの耐久性確保、EventBridge Pipes によるコードレスなイベントパイプラインなど、Azure Event Grid にはない機能を多数提供しています。カスタムイベント 100 万件あたり 1.00 USD という低コストで、サーバーレスイベント駆動アーキテクチャの中核を担います。イベントフィルタリングの柔軟性とエコシステムの成熟度において、AWS EventBridge はサーバーレスアーキテクチャの設計における最有力の選択肢です。