ApsaraMQ for MQTT のデータインバウンドルールを設定して、他の Alibaba Cloud サービスから ApsaraMQ for MQTT にデータをインポートできます。このトピックでは、他の Alibaba Cloud サービスから ApsaraMQ for MQTT にデータをインポートする際の動作メカニズム、シナリオ、および制限について説明します。また、ApsaraMQ for MQTT と他の Alibaba Cloud サービス間のリソースマッピングについても説明します。
動作メカニズム
他の Alibaba Cloud サービスから ApsaraMQ for MQTT にデータをインポートするには、データインバウンドルールを作成する必要があります。ApsaraMQ for MQTT は、データインバウンドルールを使用して他の Alibaba Cloud サービスからデータを取得します。その後、ApsaraMQ for MQTT ブローカーは、Message Queuing Telemetry Transport（MQTT）プロトコルを使用して、データを ApsaraMQ for MQTT クライアントにプッシュします。このようにして、Alibaba Cloud サービスの API オペレーションを呼び出して、ApsaraMQ for MQTT クライアントにデータを送信できます。
シナリオ
メッセージ送信
クラウドにデプロイされているバックエンドサービスアプリケーションが、ApsaraMQ for RocketMQ にメッセージを送信します。設定されたデータインバウンドルールに基づいて、ApsaraMQ for MQTT は ApsaraMQ for RocketMQ のトピックのデータを ApsaraMQ for MQTT のトピックにマッピングし、そのデータを宛先 ApsaraMQ for MQTT クライアントにプッシュします。
注意事項
ApsaraMQ for MQTT がデータインフロールールを使用して ApsaraMQ for RocketMQ からメッセージを受信する場合、ApsaraMQ for MQTT クライアントは、ApsaraMQ for RocketMQ ブローカーが更新されている場合、遅延してメッセージを受信する可能性があります。サービス更新については、[Notice List] をご参照ください。
制限
項目 | 制限 | 説明 |
単一インスタンスのルール数 | 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 MQTT と ApsaraMQ for RocketMQ 間でデータを交換する場合、ApsaraMQ for RocketMQ 4.0 インスタンスのみを使用できます。 |
リソースマッピング方法
データインバウンドルールを使用すると、ApsaraMQ for MQTT のペアレントトピックに基づいてデータをマッピングできます。別の Alibaba Cloud サービスの特定のリソースのデータを、ApsaraMQ for MQTT のペアレントトピックにインポートできます。ApsaraMQ for MQTT のサブトピックのデータは、ApsaraMQ for Apache RocketMQ のメッセージプロパティにマッピングされます。
表 1. マッピング
ApsaraMQ for MQTT リソース | Alibaba Cloud サービス | Alibaba Cloud サービスのリソース | パケット定義 |
ApsaraMQ for MQTT のトピック | ApsaraMQ for RocketMQ | ApsaraMQ for RocketMQ のトピック | ApsaraMQ for MQTT と ApsaraMQ for Apache RocketMQ 間のメッセージ構造マッピング |
関連情報
ApsaraMQ for RocketMQ コンソールの操作については、データインバウンドルールの管理 をご参照ください。