このトピックでは、ApsaraMQ for RabbitMQ コンソールで sink タスクを作成し、ApsaraMQ for RabbitMQ から Simple Message Queue (旧称：MNS) にデータをエクスポートする方法について説明します。
前提条件
ApsaraMQ for RabbitMQ インスタンスが購入・デプロイ済みである必要があります。また、インスタンスのステータスが 実行中 であることを確認してください。詳細については、「リソースの作成」をご参照ください。
SMQ キューが作成済みである必要があります。詳細については、「SMQ の有効化と RAM ユーザーによる SMQ アクセス権限の付与」をご参照ください。
EventBridge が有効化されており、Resource Access Management (RAM) ユーザーに必要な権限が付与済みである必要があります。詳細については、「EventBridge の有効化と権限付与」をご参照ください。
利用可能なリージョン
Simple Message Queue (旧称：MNS) は、以下のリージョンで sink として利用可能です：中国 (杭州)、中国 (上海)、中国 (青島)、中国 (北京)、中国 (張家口)、中国 (フフホト)、中国 (深セン)、中国 (成都)、中国 (香港)、米国 (シリコンバレー)、米国 (バージニア)、ドイツ (フランクフルト)、シンガポール、日本 (東京)、マレーシア (クアラルンプール)、インドネシア (ジャカルタ)。
sink タスクの作成
-
ApsaraMQ for RabbitMQ コンソール にログインします。左側ナビゲーションウィンドウで、 を選択します。
-
上部ナビゲーションバーで、たとえば 中国 (杭州) のようなリージョンを選択します。タスクリスト ページで、タスクの作成 をクリックします。
-
タスクの作成 ページで、タスク名 および 説明 を設定し、画面上の指示に従ってその他のパラメーターを構成します。その後、保存 をクリックします。以下に各パラメーターの説明を示します：
-
タスク作成
-
Source (ソース) ステップで、データプロバイダー を ApsaraMQ for RabbitMQ に設定し、以下のパラメーターを構成した後、次へ をクリックします。
パラメーター
説明
例
リージョン
メッセージ sink タスクを作成する際に選択したリージョンが使用されます。このパラメーターは変更できません。
中国 (杭州)
RabbitMQ インスタンス
メッセージを生成するソースの ApsaraMQ for RabbitMQ インスタンスを選択します。
amqp-cn-******lpc00a
vhost
ソースの ApsaraMQ for RabbitMQ インスタンスの vhost を選択します。
test
Queue
ソースの ApsaraMQ for RabbitMQ インスタンスのキューを選択します。
queue_test
一括プッシュの件数
関数へ送信される 1 バッチあたりの最大メッセージ数です。累積メッセージ数が指定値に達した場合にのみリクエストが送信されます。値の範囲は [1, 10000] です。
100
バッチプッシュ間隔 (単位：秒)
関数を呼び出す間隔です。システムはメッセージを集約し、指定された間隔で Function Compute へ送信します。値の範囲は [0, 15] であり、単位は秒です。値が 0 の場合は、待機せずに即時配信されます。
3
-
Filtering (フィルタリング) ステップで、パターン内容 を設定してイベントをフィルター処理します。詳細については、「イベントパターン」をご参照ください。
-
Transform (変換) ステップで、データクレンジングを構成して、分割、マッピング、エンリッチメント、動的ルートなどの複雑なデータ変換タスクを実行します。詳細については、「Function Compute を使用したメッセージデータのクレンジング」をご参照ください。
-
Sink (ターゲット) 構成ウィザードで、サービスタイプ を Message Service MNS に設定し、以下のパラメーターを構成します。
パラメーター
説明
例
キュー名
ソースからメッセージを受信する送信先の Simple Message Queue (旧称：MNS) キューを選択します。
test
Base64 エンコーディングの有効化
-
はい：Base64 エンコーディングを有効化します。データは Simple Message Queue (旧称：MNS) のキューへ配信される前にエンコードされます。
-
いいえ：Base64 エンコーディングを無効化します。
はい
メッセージ本文
イベントコンテンツの変換タイプを選択します。詳細については、「イベントコンテンツの変換」をご参照ください。
完全なデータ
-
-
-
タスクのプロパティ
失敗したイベントに対するリトライポリシーおよびエラー処理方法を構成します。詳細については、「リトライとデッドレターキュー」をご参照ください。
-
その他の操作
タスクリスト ページで、管理対象のタスクを見つけ、[アクション] 列で操作を実行します。
-
タスクの詳細表示： 詳細 をクリックします。メッセージシンクの詳細 ページでは、タスクのソース、シンク、およびリソース構成を確認できます。
-
タスクの編集： 編集 をクリックします。メッセージシンクの編集 パネルで、リソース構成 および ルール構成 を変更できます。
-
タスクの有効化／無効化： 有効化 または 無効化 をクリックします。表示される 注意事項 ダイアログボックスで、確認 をクリックします。
-
タスクの削除： 削除 をクリックします。表示される 注意事項 ダイアログボックスで、確認 をクリックします。