データアウトバウンドルールは、ApsaraMQ for MQTT のトピックに公開されたメッセージを他の Alibaba Cloud サービスに転送します。ルールがアクティブになると、メッセージは自動的に送信先サービスに配信され、その API を通じて利用できます。現在、送信先としてサポートされているのは ApsaraMQ for RocketMQ 4.0 のみです。
仕組み
データアウトバウンドルールを作成する際、ソース MQTT トピックと送信先 RocketMQ トピックを指定します。ApsaraMQ for MQTT は、ソース トピックに公開されたすべてのメッセージを継続的に送信先トピックに転送します。その後、ApsaraMQ for RocketMQ API を通じてこれらのメッセージを利用できます。
ApsaraMQ for MQTT は複数レベルのトピックをサポートしていますが、ApsaraMQ for RocketMQ は単一レベルのトピックのみをサポートしています。転送中、レベル 1 の MQTT トピックは RocketMQ トピックにマッピングされ、サブレベルの MQTT トピックは RocketMQ のメッセージプロパティにマッピングされます。詳細については、「ApsaraMQ for MQTT と ApsaraMQ for RocketMQ 間のメッセージ構造のマッピング」をご参照ください。
データアウトバウンドルールの作成
開始する前に、以下のものがあることを確認してください：
カーネルバージョンが V3.x.x の ApsaraMQ for MQTT インスタンス
MQTT インスタンスと同じリージョンにある ApsaraMQ for RocketMQ 4.0 インスタンス
両方のインスタンスで作成されたトピック
MQTT インスタンスのカーネルバージョンは、インスタンス一覧、または ApsaraMQ for MQTT コンソール の [インスタンスの詳細]
データアウトバウンドルールを作成するには：
ApsaraMQ for MQTT コンソールにログインします。左側のナビゲーションウィンドウで、[インスタンス] をクリックします。
上部のナビゲーションバーで、インスタンスが存在するリージョンを選択します。[インスタンス] ページで、インスタンス名をクリックして [インスタンス詳細] ページに移動します。
左側のナビゲーションウィンドウで、ルール管理 をクリックします。ルール管理 ページの左上隅にある ルールの作成 をクリックします。
基本情報の設定 ステップで、以下のパラメーターを設定し、次へ をクリックします。
パラメーター 必須 例 説明 ルール ID はい 111111 グローバルに一意な識別子。使用できる文字は、英字、数字、ハイフン (-)、アンダースコア (_) です。少なくとも 1 つの英字または数字を含める必要があります。長さは 3～64 文字です (長い場合は自動的に切り捨てられます)。作成後は変更できません。 説明 いいえ migrate from rocketmq ルールの説明。 ステータス はい 有効 作成時にルールを有効にするかどうか。有効な値：[有効]、[無効]。 ルールタイプ はい データアウトバウンド ルールのタイプ。有効な値：データアウトバウンド：MQTT メッセージを別の Alibaba Cloud サービスに転送します。詳細については、「ApsaraMQ for MQTT から他の Alibaba Cloud サービスへのデータのエクスポート」をご参照ください。データインバウンド：他の Alibaba Cloud サービスから ApsaraMQ for MQTT にデータをインポートします。詳細については、「他のクラウドサービスから ApsaraMQ for MQTT へのデータのインポート」をご参照ください。クライアントステータス通知：ApsaraMQ for MQTT クライアントのステータスイベントを他の Alibaba Cloud サービスにエクスポートします。詳細については、「ApsaraMQ for MQTT クライアントのステータスイベントのエクスポート」をご参照ください。 ルールソースの設定 ステップで、ソース トピックを指定し、次へ をクリックします。
重要ApsaraMQ for MQTT は複数レベルのトピックをサポートしていますが、ApsaraMQ for RocketMQ は単一レベルのトピックのみをサポートしています。レベル 1 の MQTT トピックは RocketMQ トピックにマッピングされ、サブレベルの MQTT トピックは RocketMQ のメッセージプロパティにマッピングされます。詳細については、「ApsaraMQ for MQTT と ApsaraMQ for RocketMQ 間のメッセージ構造のマッピング」をご参照ください。
パラメーター 必須 例 説明 トピック はい Topic A データをエクスポートする MQTT トピック。 [ルール送信先の設定] ステップで、送信先を指定し、作成 をクリックします。
パラメーター 必須 例 説明 送信先サービスタイプ はい Message Queue for Apache RocketMQ ApsaraMQ for RocketMQ のみがサポートされています。 Message Queue for Apache RocketMQ インスタンス はい MQ_INST_13801563067\*\*\*\*\*\_BbyOD2jQ RocketMQ インスタンスの ID。MQTT インスタンスと同じリージョンにある必要があります。 トピック はい Topic B RocketMQ インスタンスの送信先トピック。ソース MQTT トピックからのメッセージはここに転送されます。
ルールが作成されると、ルール管理 ページに表示されます。
MQTT メッセージが RocketMQ メッセージにどのようにマッピングされるかについての詳細は、「ApsaraMQ for MQTT と ApsaraMQ for RocketMQ 間のメッセージ構造のマッピング」をご参照ください。
データアウトバウンドルールの編集
[ルール] ページで、対象のルールを見つけます。[操作] 列で、[その他] > [編集] を選択します。
[ルールの編集] ページで、ルール ID 以外のパラメーターを変更します。
[ルール送信先の設定] ステップで [保存] をクリックします。
データアウトバウンドルールの削除
[ルール] ページで、対象のルールを見つけます。[操作] 列で、[その他] > [削除] を選択します。
確認ダイアログボックスで、[OK] をクリックします。
データアウトバウンドルールの有効化
[ルール] ページで、対象のルールを見つけます。[操作] 列で、[その他] > [有効] を選択します。
確認ダイアログボックスで、[OK] をクリックします。
データアウトバウンドルールの無効化
[ルール] ページで、対象のルールを見つけます。[操作] 列で、[その他] > [無効] を選択します。
確認ダイアログボックスで、[OK] をクリックします。