EventBridge:EventBridge とは

イベントバス

イベントバスは EventBridge のコアとなるルーティングリソースです。イベントを受信し、1 つ以上のターゲットに配信します。

CloudEvents 1.0 標準に基づいて、イベントバスは Alibaba Cloud サービス、カスタムアプリケーション、または SaaS アプリケーションからのイベントを受け入れます。イベントルールを設定することで、イベントはフィルタリングおよび変換された後、Function Compute、ApsaraMQ for RocketMQ、DingTalk などのターゲットサービスに配信されます。

主な機能

• コンテンツフィルタリング：イベントルールを使用して、イベントのコンテンツに基づいてフィルタリングします。

• イベント変換：ルーティング中にイベントの構造を変更し、ターゲットシステムが必要とするデータ形式に合わせます。

• 複数ターゲットへの配信：1 回のパブリッシュで複数のダウンストリームサービスをトリガーし、イベントを処理します。

代表的なシナリオ

• マイクロサービスのデカップリング：注文サービスが「注文作成」イベントをパブリッシュします。在庫、物流、特典の各サービスは、互いを意識することなく、独立してこのイベントをサブスクライブします。

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

• 自動化された O&M：Cloud Monitor がインスタンスの障害イベントを検出すると、自動的に O&M スクリプトをトリガーするか、アラート通知を送信します。

イベントストリーム

イベントストリームは、EventBridge における高スループットのデータ転送リソースです。大量データの継続的な収集とリアルタイム処理を担います。

イベントバスの多対多 (N:M) のルーティングとは異なり、イベントストリームは高スループットで順序付きデータのシナリオ向けに設計された 1 対 1 (1:1) のデータ転送サービスを提供します。ログ、監視メトリクス、ユーザー行動データなどの継続的なデータストリームの処理に適しています。

主な機能

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

• 消費リプレイ：過去の特定の時点からデータをプルして再処理することをサポートします。

代表的なシナリオ

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

• IoT データ収集：膨大な数のデバイスから報告されるステータスデータをイベントストリームを通じて集約し、ダウンストリームの分析システムに配信します。

• クリックストリーム分析：ウェブサイトやアプリ上のユーザー行動データをリアルタイムでキャプチャし、推奨システムで利用します。

EventHouse

EventHouse は、EventBridge における構造化されたイベントストレージおよび分析リソースです。EventHouse を有効にすると、EventBridge を通過するすべてのイベントデータが永続的に保存され、いつでもクエリおよび分析が可能になります。

EventHouse は、カラムナおよび階層型ストレージアーキテクチャを使用して、クエリパフォーマンスを確保しながらストレージコストを削減します。トレーサビリティとディザスタリカバリのためにイベント履歴を保持するだけでなく、即時 SQL クエリをサポートしてイベントデータをビジネスインサイトに変換します。

主な機能

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

• 低コストのレイクハウスストレージ：大量のイベントデータを長期間保持するのに適した階層型ストレージアーキテクチャを使用します。

代表的なシナリオ

• インテリジェント O&M と根本原因分析：システム障害発生時に、SQL を使用して障害タイムウィンドウ内の異常なイベントの連鎖を迅速に取得し、根本原因を特定できます。

• ビジネスインテリジェンスレポート：Quick BI などのツールを EventHouse に接続して、イベントストリームに基づいたリアルタイムのビジネスレポートを生成できます。

• イベント監査とコンプライアンス：ビジネスイベントのレコードを長期間保持して、監査およびコンプライアンスの要件を満たすことができます。

選択方法

シナリオに基づいて適切なリソースを選択してください：

• 複数のソースから複数のターゲットにイベントをルーティングする場合は、イベントバスを使用します。例えば、注文イベントが在庫、物流、特典の各システムに同時に通知する必要がある場合などです。

• 2 つのシステム間で高スループットのデータパイプラインを構築する場合は、イベントストリームを使用します。例えば、データベースの変更ログをダウンストリームの分析システムに継続的に同期する場合などです。

• 履歴イベントデータを保存してクエリする場合は、EventHouse を使用します。例えば、過去 1 か月間のすべての失敗した支払いイベントの分布を分析する場合などです。

注：これら 3 つのリソースは組み合わせて使用できます。例えば、イベントバスがイベントを受信してルーティングし、イベントストリームが高スループットのチャネルを提供し、EventHouse が履歴データを保存してクエリと分析を行う、といった構成が可能です。