EventBridge:EventBridge とは

イベントバス

イベントバスは、イベントを受信し、設定可能なイベントルールに基づいて 1 つ以上のターゲットに配信します。

イベントは、Alibaba Cloud サービス、カスタムアプリケーション、または SaaS プラットフォームから到着します。各イベントルールは、フィルター条件と 1 つ以上の配信ターゲット (Function Compute、ApsaraMQ for RocketMQ、DingTalk など) を定義します。ルーティング中に、イベント構造は各ターゲットが期待する形式に合わせて変換されます。

主な機能

• コンテンツフィルタリング：イベントルールを使用して、ペイロードコンテンツによりイベントをマッチングします。

• イベント変換：ルーティング中にイベントデータを再構成し、各ターゲットが期待する形式に合わせます。

• 複数ターゲットへの配信：単一のイベントを複数のダウンストリームサービスに同時に配信します。

ユースケース

• マイクロサービスの疎結合化：注文サービスが "Order Created" イベントを公開します。在庫、物流、ポイント付与サービスはそれぞれ独立してサブスクライブし、相互に直接依存しません。

• SaaS 統合：Salesforce で顧客情報が変更されると、更新が自動的に内部 CRM システムに同期されます。

• 自動 O&M：Cloud Monitor がインスタンス障害を検出し、修復スクリプトをトリガーするか、アラート通知を送信します。

イベントストリーム

イベントストリームは、大規模データの継続的な収集とリアルタイム処理のための、高スループットな一対一 (1:1) データチャネルを提供します。イベントバスの多対多ルーティングとは異なり、イベントストリームは、ログ、監視メトリクス、ユーザー行動イベントなどの順序付けられた大量データに最適化されています。

主な機能

• 高スループット、低レイテンシー：書き込みと読み取りの両方で、毎秒数百万トランザクション (TPS) を処理します。

• 消費リプレイ：過去の特定のポイントからデータを取得して再処理します。

ユースケース

• リアルタイムデータウェアハウス：ビジネスデータベースからのバイナリログ (binlog) とアプリケーションログをリアルタイムで収集し、Flink で処理して、結果をデータウェアハウスに書き込みます。

• IoT データ集約：多数のデバイスからのステータスデータを集約し、ダウンストリーム分析システムに配信します。

• クリックストリーム分析：Web サイトやアプリからユーザー行動データをリアルタイムでキャプチャし、レコメンデーションシステムに提供します。

イベントハウス

イベントハウスは、EventBridge を通過するすべてのイベントデータを永続的に保存し、いつでも SQL ベースでクエリできます。カラムナー、階層型ストレージアーキテクチャにより、クエリパフォーマンスを維持しながらストレージコストを低く抑え、長期保存とリアルタイム分析の両方に適しています。

主な機能

• 即時 SQL クエリ：データを別のデータウェアハウスに移動することなく、履歴イベントに対して標準 SQL クエリを直接実行します。多次元集約、フィルタリング、分析をサポートします。

• 低コストレイクハウスストレージ：大規模イベントデータセットの長期保存に最適化された階層型ストレージアーキテクチャです。

ユースケース

• 根本原因分析：システム障害発生時に、障害時間帯内の異常イベントのチェーンをクエリして、根本原因を特定します。

• ビジネスインテリジェンスレポート：Quick BI などのツールをイベントハウスに接続し、イベントストリームからリアルタイムレポートを生成します。

• イベント監査とコンプライアンス：規制および監査要件を満たすため、ビジネスイベント記録を長期保存します。

適切なリソースの選択

これら 3 つのリソースは連携して機能します。イベントバスはイベントを受信してルーティングし、イベントストリームは 2 つのシステム間に高スループットチャネルを提供し、イベントハウスはクエリと分析のためにすべての履歴データを保存します。