ApsaraMQ for RocketMQ:メッセージ統合

機能

• 豊富なデータソースとの統合

  Alibaba Cloud、マルチクラウド、ハイブリッドクラウドの各シナリオにまたがるデータを接続します。複数のクラウド製品からのログ取り込み、およびログ、データベース、メッセージミドルウェアなどを含むセルフマネージド環境とマルチクラウド環境向けのデータソース統合をサポートします。

• データクレンジングとストリーミング

  UI ベースの抽出、変換、ロード (ETL) 設定を提供し、メッセージキューに流入するデータのクレンジング、整形、変換を行い、処理済みデータを下流システムにダンプします。

• サーバーレスのカスタム処理

  Function Compute (FC) を活用し、サーバーレスプラットフォーム上でデータ処理と配信のためのカスタムビジネスロジックを記述できます。

制限事項

次の表に、メッセージ統合の制限事項を示します。

概念：メッセージ流入 (ソース)

メッセージ流入 (ソース) は、メッセージ、ログ、リレーショナルデータ、非リレーショナルデータなどのさまざまなデータタイプをメッセージング製品にストリーミング取り込みするデータ取り込みコンポーネントです。データセンターとクラウドにまたがる柔軟で非侵襲的な統合をサポートし、ソース管理、フィルタリング、運用と保守 (O&M)、モニタリングを標準で提供します。

概念：メッセージ流出 (シンク)

メッセージ流出 (シンク) は、メッセージング製品からさまざまなデータターゲットへデータをストリーミングします。メッセージを高い信頼性で配信し、配信中のデータクレンジングとフィルタリングをサポートします。

概念：データ処理 (変換)

メッセージの流入タスクまたは流出タスクを設定する際に、データ処理を設定できます。データ処理は、EventBridge の独自の処理エンジンとカスタム Function Compute 機能を利用します。メッセージの変換、処理、分析のために、7 つの一致パターン (完全一致、プレフィックス、サフィックス、指定値以外、数値、配列、複雑なロジック) と 5 つのルールコンバーター (完全なイベント、部分的なイベント、定数、テンプレートコンバーター、Function Compute テンプレートコンバーター) を提供します。

概念：タスク

タスクとは、メッセージ統合を実装するリソースエンティティです。ソース、ターゲット、および設定済みのフィルターおよび変換ルールで構成されます。基盤となるリソースは、EventBridge のイベントストリーミング機能です。

各タスクは、リソース構成とデータ処理の 2 つのパートで構成されています。リソース構成では、タスクのソースとターゲットを定義します。データ処理の詳細については、「概念： データ処理 (Transform)」をご参照ください。