このトピックでは、メッセージ統合の機能と制限について説明します。また、メッセージ統合で使用される基本用語についても説明します。
背景情報
デジタルトランスフォーメーションの過程において、企業は、情報を統合するための集中化された方法の欠如、さまざまなデータ形式や種類による非効率的なデータ転送と統合、データとバックエンドサービスを共有するためのサービスの欠如、クラウドベースのリソースとオンプレミスのリソースを接続するための安全なチャネルの欠如など、さまざまな課題に直面しています。これらの課題を解決するために、Alibaba Cloud は、メッセージ統合と呼ばれるフルスタックのメッセージおよびデータ統合モジュールを提供しています。このモジュールは、メッセージ統合プロセスを簡素化し、リージョンをまたがるクラウドベースとオンプレミスの統合をサポートします。
メッセージ統合は、メッセージングサービス向けのローコードおよびフルスタックのイベントストリーム処理を提供します。メッセージ統合、データ接続、データ処理、サービス統合などのシナリオに重点を置いて、メッセージ統合は、統合タスクを簡単に作成および調整できる視覚化されたユーザーインターフェースを提供します。メッセージ統合では、リージョン、インスタンス、およびアプリケーションをまたがるデバイスを接続することもできます。これにより、メッセージ統合と開発のコストを削減できます。

機能
さまざまなデータソース
メッセージ統合は、クラウド内およびクラウド間で保存されているデータを接続することを目的としています。メッセージ統合を使用すると、クラウド内のさまざまなサービスのログや自己管理アプリケーションから宛先サービスにデータをインポートできます。クラウド間のデータインポートもサポートされています。
データクレンジングとデータ流出
メッセージ統合は、強力な UI ベースの抽出、変換、ロード (ETL) 機能を提供します。この機能を使用して、メッセージキューで受信したデータをクレンジングおよびフォーマットし、データの形式を変換できます。メッセージ統合では、抽出、変換、ロードされたデータをダウンストリームシステムにダンプすることもできます。
サーバーレスカスタム処理
Alibaba Cloud が提供するサーバーレスコンピューティングサービスである Function Compute によって提供されるカスタムコーディング機能を活用することで、メッセージ統合では、カスタムビジネスロジックを記述し、カスタムデータ処理と配信を完了できます。
制限
次の表は、メッセージ統合の制限について説明しています。
項目 | 説明 |
タスク数 | 1 つのリージョンにおけるメッセージ流入タスクと流出タスクの合計数は 20 を超えることはできません。タスク数を増やす場合は、 チケットを送信してください。 |
タスク名 | 名前には、文字、数字、ハイフン (-) を使用でき、文字または数字で始める必要があります。名前の長さは最大 127 文字です。指定した名前の長さが 127 文字を超える場合、システムは値を切り捨てます。 |
イベントパターン | stringExpression パターンでは、各フィールドに map データ構造の式を最大 5 つ含めることができます。 |
イベント変換 |
|
極端な場合のデータ損失 | 詳細については、「再試行ポリシーとデッドレターキュー」をご参照ください。 |
メッセージ流入 (ソース)
メッセージ流入 (ソース) は、メッセージ統合のコンポーネントです。メッセージ、ログ、リレーショナルデータ、非リレーショナルデータなど、複数のデータソース間のデータを柔軟、迅速、非侵入的に統合できます。メッセージ流入は、データセンターとクラウドをまたがるデータ統合ソリューションの実装に役立ち、統合されたデータを操作、管理、監視するための機能を提供します。メッセージ流入の主な機能は、さまざまな種類のデータをメッセージングサービスにインポートすること、およびさまざまなソースからのデータを管理およびフィルタリングすることです。

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

データ処理 (変換)
データ処理 (変換) は、メッセージ統合の重要なコンポーネントです。この機能は、メッセージ流入タスクまたは流出タスクを作成する際にオプションです。メッセージ統合は、EventBridge によって提供されるデータ処理機能と Function Compute によって提供されるカスタム定義機能に基づいて、7 つのマッチングモードと 5 つのトランスフォーマーを提供し、メッセージを効率的に変換、処理、分析します。マッチングモードは、固定値マッチング、プレフィックスマッチング、サフィックスマッチング、除外ベースのマッチング、数値マッチング、配列マッチング、および複合条件マッチングです。トランスフォーマーは、完全イベント、部分イベント、定数、テンプレート、および Function Compute テンプレートです。
タスク
タスクは、メッセージ統合を実行するリソースエンティティです。タスクは、メッセージ統合を実装するために使用される方法でもあります。ほとんどの場合、タスクは、ソース、宛先、フィルタリングルール、および変換ルールで構成されます。タスクの基盤となるリソースは、EventBridge のイベントストリーム機能です。
タスクを作成するときは、リソースとデータを処理する方法を指定する必要があります。リソースの構成はタスクの重要な部分であり、ソースと宛先の構成が含まれます。データ処理については、「データ処理 (変換)」をご参照ください。
タスクを作成した後、タスクに構成したリソースの種類を変更することはできません。