すべてのプロダクト
Search
ドキュメントセンター

ApsaraMQ for MQTT:データインバウンドルールの管理

最終更新日:Jan 14, 2025

他の Alibaba Cloud サービスから ApsaraMQ for MQTT にデータをインポートするには、データインバウンドルールを作成する必要があります。ApsaraMQ for MQTT は、データインバウンドルールを使用して他の Alibaba Cloud サービスからデータを取得し、Message Queuing Telemetry Transport(MQTT)プロトコルを使用して ApsaraMQ for MQTT クライアントにデータをプッシュします。このようにして、Alibaba Cloud サービスの API オペレーションを呼び出して、ApsaraMQ for MQTT クライアントにデータを送信できます。

プロセス

数据流入

制限

項目

制限

説明

単一インスタンスのルール数

100

デフォルト値がビジネス要件を満たしていない場合は、DingTalkグループ 35228338 に参加して ApsaraMQ for MQTT テクニカルサポートにお問い合わせください。

ルールの重複排除

各内部リソースに対して、同じタイプのルールは 1 つだけ作成できます。

たとえば、各グループ ID に対してクライアントステータス通知のルールを 1 つだけ作成でき、ApsaraMQ for MQTT の各トピックに対してデータインバウンドルールとデータアウトバウンドルールを 1 つずつ作成できます。

リージョン

リージョンをまたいでルールを作成することはできません。ルールのデータソースとデータデスティネーションが属するインスタンスは、同じリージョンに存在する必要があります。

たとえば、データソースが中国 (杭州) リージョンの ApsaraMQ for MQTT として指定されているデータアウトバウンドルールを作成する場合、データデスティネーションとして中国 (杭州) リージョンの ApsaraMQ for RocketMQ インスタンスのみを選択できます。

ApsaraMQ for MQTT インスタンスバージョン

カーネルバージョンが 3.x.x のインスタンスに対してのみルールを作成できます。

ApsaraMQ for MQTT インスタンスのカーネルバージョンは、ApsaraMQ for MQTTコンソール のインスタンスリストまたは [インスタンスの詳細] ページで確認できます。

ApsaraMQ for RocketMQ インスタンスバージョン

ApsaraMQ for RocketMQ 4.0 インスタンスのみがサポートされています。

データインバウンドルールまたはデータアウトバウンドルールを使用して ApsaraMQ for MQTTApsaraMQ for RocketMQ 間でデータを交換する場合、ApsaraMQ for RocketMQ 4.0 インスタンスのみを使用できます。

使用上の注意

ApsaraMQ for MQTT がデータインバウンドルールを使用して ApsaraMQ for RocketMQ からメッセージを受信する場合、ApsaraMQ for RocketMQ ブローカーが更新されていると、ApsaraMQ for MQTT クライアントがメッセージを受信する際に遅延が発生する可能性があります。サービス更新については、お知らせ一覧 を参照してください。

データインバウンドルールの作成

  1. ApsaraMQ for MQTT コンソール にログオンします。左側のナビゲーションペインで、インスタンスリスト をクリックします。

  2. 上部のナビゲーションバーで、管理するインスタンスが存在するリージョンを選択します。[インスタンス] ページで、インスタンス名をクリックして インスタンスの詳細 ページに移動します。

  3. 左側のナビゲーションペインで、ルール管理 をクリックします。[ルール] ページの左上隅にある ルールの作成 をクリックします。

  4. ルールの作成 ページで、次の手順を実行します。

    1. 基本情報の設定 ステップで、パラメーターを構成し、次へ をクリックします。次の表にパラメーターを示します。

      パラメーター

      説明

      ルール ID

      111111

      ルール ID。この ID は、ルールのグローバルに一意な識別子です。

      • ルール ID には、文字、数字、ハイフン (-)、アンダースコア (_) のみを含めることができ、少なくとも 1 つの文字または数字を含める必要があります。

      • ルール ID は 3 ~ 64 文字の長さでなければなりません。値に 64 文字を超える文字が含まれている場合、自動的に切り詰められます。

      • ルール ID は、ルール作成後に更新できません。

      説明

      RocketMQ からの移行

      ルールの説明。

      ステータス

      有効

      ルールを有効にするかどうかを指定します。有効な値:

      • 有効

      • 無効

      ルールタイプ

      データインバウンド

      ルールタイプ。有効な値:

    2. ルールソースの設定 ステップで、データソースを指定し、次へ をクリックします。

      パラメーター

      説明

      ソースサービスタイプ

      Message Queue for Apache RocketMQ

      データが ApsaraMQ for MQTT に転送されるクラウドサービス。

      説明

      ApsaraMQ for RocketMQ のみがサポートされています。

      Message Queue for Apache RocketMQ インスタンス

      MQ_INST_13801563067*****_BbyOD2jQ

      ApsaraMQ for RocketMQ インスタンスの ID。

      説明

      ApsaraMQ for MQTT インスタンスと同じリージョンにあるインスタンスのみを選択できます。

      トピック

      トピック A

      ApsaraMQ for RocketMQ インスタンスのトピック。この例では、トピック A のメッセージが ApsaraMQ for MQTT インスタンスのトピックに転送されます。

    3. ルール対象の設定 ステップで、データの転送先を指定し、作成 をクリックします。

      パラメーター

      説明

      トピック

      トピック B

      他の Alibaba Cloud サービスからのデータを転送する ApsaraMQ for MQTT トピック。

      重要

      ApsaraMQ for MQTT は複数レベルのトピックをサポートしていますが、ApsaraMQ for RocketMQ は 1 レベルのトピックをサポートしています。したがって、ApsaraMQ for MQTT のレベル 1 トピックは ApsaraMQ for RocketMQ のトピックにマッピングされ、ApsaraMQ for MQTT の他のレベルのトピックは ApsaraMQ for RocketMQ のメッセージプロパティにマッピングされます。マッピングについては、「ApsaraMQ for MQTT と ApsaraMQ for RocketMQ 間のメッセージ構造のマッピング」を参照してください。

    データインバウンドルールが作成されると、ルール管理 ページでルールを確認できます。

説明 ApsaraMQ for MQTTApsaraMQ for RocketMQ 間のメッセージ構造のマッピングについては、「Message Queue for MQTT と Message Queue for Apache RocketMQ 間のメッセージ構造のマッピング」を参照してください。

データインバウンドルールの変更

  1. ルールリストで、編集するルールを見つけます。 操作 列で、詳細 > 編集 を選択します。

  2. ルールの編集 ページで、ルール ID 以外のすべてのパラメーター値を変更できます。

  3. パラメーター値を変更した後、保存ルール対象の設定 手順でクリックします。

データインバウンドルールの削除

  1. ルールリストで、削除するルールを見つけます。 操作 列で、詳細 > 削除 を選択します。

  2. 表示されるメッセージで、[OK] をクリックします。

データインバウンドルールの有効化

  1. ルールリストで、有効にするルールを見つけます。 操作 列で、詳細 > 有効化 を選択します。

  2. 表示されるメッセージで、[OK] をクリックします。

データインバウンドルールの無効化

  1. ルールリストで、無効にするルールを見つけます。 操作 列で、詳細 > 無効化する を選択します。

  2. 表示されるメッセージで、[OK] をクリックします。

参照

ApsaraMQ for MQTT クライアントから他の Alibaba Cloud サービスにデータをプッシュする方法については、「データアウトバウンドルール」を参照してください。