ApsaraMQ for RocketMQ:メッセージ統合

機能

• 多様なデータソースの統合

  メッセージ統合は、Alibaba Cloud、マルチクラウド、およびハイブリッドクラウド環境にわたるデータを接続します。クラウドサービスからのログ取り込み、ユーザー管理のアプリケーションからのデータソース統合、およびクロスクラウド統合をサポートします。サポートされる取り込みソースには、ログ、データベース、およびメッセージミドルウェアが含まれます。

• データクレンジングとデータのエクスポート

  メッセージ統合は、UI ベースの ETL 設定を提供します。メッセージがメッセージキューに取り込まれた後、メッセージのクレンジング、フォーマット、変換を行い、処理されたデータをダウンストリーム システムにエクスポートできます。

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

  サーバーレス プラットフォームと Function Compute (FC) のカスタムコーディング機能を活用し、メッセージ統合を使用して、データ処理と配信のためのカスタム ビジネスロジックを記述できます。

制限事項

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

用語：メッセージインフロー (ソース)

メッセージインフローは、メッセージ統合のデータ統合コンポーネントです。メッセージ、ログ、リレーショナル データ、非リレーショナル データなど、複数のソースからメッセージングサービスにデータを取り込みます。データセンター間およびクロスクラウド統合をサポートし、統合されたデータを個別に操作、管理、監視できます。ソース レベルで受信データをフィルターすることもできます。

用語：メッセージアウトフロー (シンク)

メッセージアウトフローは、メッセージングサービスからさまざまなデスティネーション サービスにデータをエクスポートします。メッセージを確実に配信し、配信中にデータをクレンジングし、フィルターします。

用語：データ処理 (変換)

データ処理は、メッセージインフローまたはメッセージアウトフロー タスク用に設定できるオプションのコンポーネントです。EventBridge と FC 上に構築されており、7 つの一致モード (固定値一致、プレフィックス一致、サフィックス一致、除外ベース一致、数値一致、配列一致、および複合条件一致) と 5 つのトランスフォーマー (完全なイベント、部分的なイベント、定数、テンプレート、および FC テンプレート) を提供し、メッセージの変換、処理、および分析を行えるようにします。

用語：タスク

通常、タスクはソース、デスティネーション、および設定されたフィルタリングルールと変換ルールで構成されます。これはメッセージ統合の実行単位であり、EventBridge のイベントストリーム機能によって実現されています。

各タスクには、リソース設定 (ソースとデスティネーションの設定) とオプションのデータ処理が含まれます。詳細については、「用語：データ処理 (変換)」をご参照ください。