メッセージ統合は、メッセージングとデータ統合を簡素化する、ローコードのフルスタックイベントストリーミング (EventStreaming) プラットフォームです。このトピックでは、メッセージ統合の機能と使用制限について説明し、その中核となる用語を解説します。
背景情報
デジタルトランスフォーメーションを進める企業は、多くの場合、次のような課題に直面します。
情報統合のための統一された経路がない
多様なデータ形式により、データ転送と統合が複雑化する
データとバックエンドサービスを共有するための便利なサービスがない
クラウドとオンプレミスネットワーク間に安全な情報チャネルがない
メッセージ統合は、メッセージ統合、データ接続、データ処理、サービス統合などのシナリオに焦点を当てています。ビジュアルデザインとオーケストレーションをサポートする視覚的なインターフェイスで統合タスクを作成できます。メッセージ統合は、クラウドとオンプレミス環境間、およびリージョン間の統合をサポートし、リージョン、インスタンス、アプリケーション間の接続性を提供します。これにより、メッセージング領域における統合と開発のコストを削減できます。
機能
メッセージ統合は、次の機能を提供します。
多様なデータソース統合 — メッセージ統合は、Alibaba Cloud パブリッククラウド、マルチクラウド、ハイブリッドクラウドの各シナリオ間でデータを接続します。複数のクラウドサービスからのログの取り込み、ユーザー管理シナリオのデータソース統合、クラウド間のデータソース統合をサポートします。ログ、データベース、メッセージングミドルウェアなどのシナリオでデータの取り込みが可能です。
データクレンジングとデータアウトフロー — メッセージ統合は、UI ベースの ETL (抽出、変換、ロード) 設定を提供します。メッセージキューに送信され、書き込まれたデータをクレンジング、フォーマット、変換し、処理されたデータをダウンストリームシステムにエクスポートできます。
サーバーレスカスタム処理 — Message Integration は、Function Compute (FC) のサーバーレスプラットフォームとカスタムコーディング機能を基盤としています。Function Compute 上で独自のビジネスロジックを記述して、カスタムデータ処理と配信を実装できます。
データ処理と変換 — データ処理では、固定値照合、プレフィックス照合、サフィックス照合、除外ベースの照合、数値照合、配列照合、複合条件照合の 7 つの照合モードと、完全なイベント、部分的なイベント、定数、テンプレートコンバーター、Function Compute テンプレートコンバーターの 5 つのルールコンバーターが提供されます。 これらの照合モードとルールコンバーターを使用して、メッセージを変換、処理、分析できます。
使用制限
次の表に、メッセージ統合を使用する際に適用される制限を示します。
| 項目 | 説明 |
| タスク数 | リージョンごとに最大 20 個のタスクを作成できます。この合計には、メッセージインフローとメッセージアウトフローの両方のタスクが含まれます。上限の引き上げをご希望の場合は、チケットを送信してください。 |
| タスク名 | 名前は、英字または数字で始まる必要があります。名前に使用できるのは、英字、数字、ハイフン (-) です。名前は最大 127 文字です。127 文字を超える名前は自動的に切り捨てられます。 |
| イベントパターンマッチング | stringExpression モードでは、各フィールドにマップデータ構造で最大 5 つの式を含めることができます。 |
| イベント変換 |
|
| 極端なケースでのデータ損失 | 極端なケースでは、データ損失が発生する可能性があります。詳細については、「リトライポリシーとデッドレターキュー」をご参照ください。 |
用語
メッセージ統合は、ソースからシンクへデータを移動し、その際にオプションでデータ処理を行います。メッセージインフローはソースコンポーネント、データ処理は変換コンポーネント、メッセージアウトフローはシンクコンポーネントであり、タスクはそれらを実行するリソースエンティティです。
メッセージインフロー (ソース)
メッセージインフローは、メッセージのデータ統合コンポーネントです。メッセージ、ログ、リレーショナルデータ、非リレーショナルデータなど、さまざまなデータソースに対して、柔軟で高速かつ非侵入的なデータ統合を提供します。メッセージインフローは、サーバールーム、データセンター、クラウド間のデータ統合をサポートし、統合されたデータをユーザー自身で運用および監視できます。メッセージインフローは、さまざまなタイプのデータをメッセージングサービスにルーティングし、異なるオリジンからのソースデータを確実に管理すると同時に、そのソースデータをスクリーニングおよびフィルタリングします。
データ処理 (変換)
データ処理は、メッセージ統合の中核コンポーネントです。メッセージインフローまたはメッセージアウトフローのタスクを設定する際に、オプションでデータ処理を設定できます。データ処理は、EventBridge の組み込みデータ処理機能と FC のカスタムコーディング機能に基づいて構築されています。データ処理を使用して、メッセージを変換、処理、分析できます。データ処理が提供するマッチングモードとルールコンバーターの詳細については、「機能」をご参照ください。
メッセージアウトフロー (シンク)
メッセージアウトフローは、メッセージングサービスからさまざまなデータ宛先にデータをエクスポートします。メッセージ統合は、メッセージングサービスのメッセージを確実に配信し、配信中にメッセージデータをクレンジングおよびフィルタリングします。
タスク
タスクは、メッセージ統合の具体的な実装であり、メッセージ統合を実行するリソースエンティティです。通常、タスクは、ソース、宛先、およびそれらに対して設定されたフィルタリングと変換のルールで構成されます。タスクの基盤となるリソースは、EventBridge のイベントストリーミング (EventStreaming) 機能です。
タスクには、リソース設定とデータ処理の 2 つの部分があります。リソース設定はタスクのソースと宛先の設定を定義し、タスクの必須部分です。データ処理の詳細については、「データ処理 (変換)」をご参照ください。
タスクを作成した後、メッセージインフローまたはメッセージアウトフローのリソースタイプは読み取り専用になります。