ApsaraMQ for RocketMQ:概要

特徴

• 多様なデータソースに対応

  メッセージ統合は、クラウド内およびクラウド間に保存されているデータを接続することを目的とします。 Message Integrationを使用すると、クラウド内のさまざまなサービスのログおよび自己管理アプリケーションからのデータを宛先サービスに同期できます。 クラウド間のデータ同期もサポートされています。 Message Integrationを使用して、ログ、データベース、およびメッセージングミドルウェアからのデータを同期できます。

• データクレンジングとデータ流出

  メッセージ統合は、強力なUIベースの抽出変換ロード (ETL) 機能を提供します。 この機能を使用して、メッセージキューで受信したデータをクレンジングおよびフォーマットし、データのフォーマットを変換できます。 メッセージ統合では、ETL処理後にダウンストリームアプリケーションにデータをダンプすることもできます。

• Serverlessカスタム処理

  Message Integrationは、Alibaba Cloudが提供するサーバーレスコンピューティングサービスであるFunction Computeが提供するカスタムコーディング機能を活用することで、カスタムビジネスロジックを作成し、カスタムデータの処理と配布を完了できます。

制限事項

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

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

Message InflowまたはSourceは、Message Integrationのコンポーネントです。 Message Inflowを使用すると、メッセージ、ログ、リレーショナルデータ、非リレーショナルデータなどのデータを複数のデータソース間で、柔軟で迅速かつ非侵入的な方法で統合できます。 Message Inflowは、データセンターやクラウドにまたがるデータ統合ソリューションの実装に役立ち、統合データの操作、管理、監視に役立つ機能を提供します。 Message Inflowの主な機能は、さまざまなタイプのデータをメッセージングサービスに同期し、さまざまなソースからのデータを管理およびフィルタリングすることです。

メッセージの流出 (シンク)

Message Outflow (シンク) の主な機能は、メッセージングサービスからさまざまな宛先サービスにデータをエクスポートすることです。 Message Integrationは、メッセージングサービスからメッセージを確実に配信し、配信中にメッセージデータをクリーンアップおよびフィルタリングします。

データ処理 (変形)

データ処理、または変換は、メッセージ統合の重要なコンポーネントです。 この機能は、メッセージの流入または流出タスクを作成する場合はオプションです。 Message Integrationは、EventBridgeが提供するデータ処理機能とFunction Computeが提供するカスタム定義機能に基づいて、7つのマッチングモードと5つのトランスフォーマーを提供し、メッセージを効率的に変換、処理、分析します。 マッチングモードは、固定値マッチング、プレフィックスマッチング、サフィックスマッチング、除外ベースのマッチング、数値マッチング、配列マッチング、および結合条件マッチングである。 トランスフォーマーは、完全イベント、部分イベント、定数、テンプレート、およびFunction Computeテンプレートです。

タスク

タスクは、メッセージ統合を実行するリソースエンティティです。 タスクは、メッセージ統合を実装するために使用されるメソッドでもあります。 ほとんどの場合、タスクは、ソース、宛先、フィルタリングルール、および変換ルールで構成されます。 タスクの基になるリソースは、EventBridgeのイベントストリーム機能です。

タスクを作成するときは、データの処理に使用するリソースとメソッドを指定する必要があります。 リソースの構成は、タスクの重要な部分であり、ソースと宛先の構成を含む。 データ処理については、「データ処理 (変換) 」をご参照ください。