ApsaraMQ for RabbitMQ:別の ApsaraMQ for RabbitMQ インスタンスへのデータ同期

エクスポートタスクの作成

1. ApsaraMQ for RabbitMQ コンソールにログインします。左側のナビゲーションウィンドウで、コネクタのエコシステム統合 > タスクリスト を選択します。

2. トップナビゲーションバーで、中国 (杭州) などのリージョンを選択します。タスクリスト ページで、タスクの作成 をクリックします。

3. 「タスクの作成」ページで、タスク名および説明のパラメーターを設定し、画面上の指示に従って他のパラメーターを設定します。その後、[保存]をクリックします。以降のセクションでは、これらのパラメーターについて説明します。

   • タスクの作成

     1. Source (ソース) ステップで、データプロバイダー を [ApsaraMQ For RabbitMQ] に設定し、次のパラメーターを設定して、[次へ] をクリックします。

        パラメーター	説明	例
        リージョン	メッセージシンクタスクの作成時に選択したリージョンが使用されます。このパラメーターは変更できません。	中国 (杭州)
        RabbitMQ インスタンス	メッセージを生成するソースの ApsaraMQ for RabbitMQ インスタンスを選択します。	amqp-cn-******lpc00a
        vhost	ソースの ApsaraMQ for RabbitMQ インスタンスの Vhost を選択してください。	test
        Queue	ソース ApsaraMQ for RabbitMQ インスタンスのキューを選択します。	queue_test
        一括プッシュの件数	関数に送信できるバッチ内の最大メッセージ数。蓄積されたメッセージ数が指定値に達した場合にのみリクエストが送信されます。値の範囲は [1, 10000] です。	100
        バッチプッシュ間隔 (単位：秒)	関数が呼び出される間隔。システムはメッセージを集約し、指定された間隔で Function Compute に送信します。値の範囲は [0, 15] です。単位は秒です。値が 0 の場合は、待機せずにメッセージがすぐに配信されることを示します。	3

     2. 「Filtering (フィルタリング) 」ステップで、イベントをフィルタリングするには、「パターン内容」を設定します。詳細については、「イベント パターン」をご参照ください。

     3. 「Transform (変換) 」ステップで、分割、マッピング、エンリッチメント、および動的ルートなどの複雑なデータ変換タスクを実行するためのデータクレンジングを設定します。詳細については、「Function Compute を使用したメッセージのデータクレンジング」をご参照ください。

     4. Sink (ターゲット) 設定ウィザードで、サービスタイプをApsaraMQ for RabbitMQに設定し、以下のパラメーターを設定します。

        パラメーター	説明	例
        インスタンス ID	既存の ApsaraMQ for RabbitMQ インスタンスを選択します。	amqp-cn-zvp2pny6****
        Vhost	既存の Vhost を選択します。	test
        ターゲットタイプ	Exchange：プロデューサーはメッセージを Exchange に送信します。その後、Exchange はメッセージを 1 つ以上のキューにルーティングします。 Queue：各メッセージは 1 つ以上のキューに送信されます。	キューパターン
        Exchange	ターゲットタイプ を Exchange に設定した場合、ApsaraMQ for RabbitMQ でエクスチェンジを選択します。	exchange
        Queue	［ターゲットタイプ］を［Queue］に設定した場合、メッセージを受信するには、ApsaraMQ for RabbitMQ のキューを選択します。	queue
        メッセージのルーティングルール (Routing Key)	EventBridge は、JSONPath を使用してイベントからデータを抽出し、指定されたイベントコンテンツをイベントターゲットにルーティングします。このパラメーターは、ターゲットタイプ を Exchange に設定した場合に必要です。	データ抽出 $.data.key
        メッセージ本文	EventBridge は、JSONPath を使用してイベントからデータを抽出し、指定されたイベントの内容をイベントターゲットにルーティングします。	データ抽出 $.data.body
        MessageId	EventBridge は JSONPath を使用して、イベントからデータを抽出し、指定されたイベントコンテンツをイベントターゲットにルートします。	データ抽出 $.data.props.messageId
        カスタムプロパティ (Properties)	EventBridge は JSONPath を使用して、イベントからデータを抽出し、指定されたイベントコンテンツをイベントターゲットにルートします。	データ抽出 $.data.props

   • タスクプロパティ

     失敗したイベントのリトライポリシーとエラー処理のメソッドを設定します。詳細については、「リトライとデッドレターキュー」をご参照ください。

その他の操作

「タスクリスト」ページで、管理するタスクを見つけ、[操作] 列で操作を行います。

• タスクの詳細を表示するには、[詳細] をクリックします。[メッセージシンクの詳細] ページで、タスクのソース、シンク、およびリソース構成を表示できます。

• タスクの編集: [編集] をクリックします。[メッセージシンクの編集] パネルで、[リソース設定] と [ルール設定] を変更できます。

• タスクを有効化または無効化するには、[有効化] または [無効化] をクリックします。 表示される [注意] ダイアログボックスで、[確認] をクリックします。

• タスクを削除するには、[削除] をクリックします。表示される [注意] ダイアログボックスで、[確認] をクリックします。