ApsaraMQ for RabbitMQ では、メッセージトラッキングとは、プロデューサーによる発行からコンシューマーによる消費までのメッセージの完全なルートレコードです。メッセージトラッキングは、各ノードの時間、ステータス、およびその他の情報で構成されます。メッセージが期待どおりに送受信されない場合は、メッセージトラッキングをクエリして問題を分析および特定できます。このようにして、できるだけ早くビジネスを再開できます。
背景情報
ApsaraMQ for RabbitMQ では、次の方法を使用してメッセージをクエリできます。
キューによるクエリ: この方法は、メッセージが送信されるキューに関する情報のみを記録し、メッセージの送信前に指定されたメッセージ ID を記録しない、あいまいなクエリのシナリオに適しています。
メッセージ ID によるクエリ: この方法は、メッセージの送信前に指定されたメッセージ ID を記録する、正確なクエリのシナリオに適しています。詳細については、「メッセージ ID を指定するにはどうすればよいですか?」をご参照ください。
メッセージ処理時間によるクエリ: この方法は、メッセージが処理される時間範囲を記録する、あいまいなクエリのシナリオに適しています。メッセージ処理時間とは、メッセージが配信されてから、クライアントがメッセージを受信した後にクライアントが確認応答 (ACK) を送信するまでの期間を指定します。
制限事項
ApsaraMQ for RabbitMQ でメッセージトラッキング機能を使用する場合は、次の制限事項に注意してください。
ApsaraMQ for RabbitMQ インスタンスでメッセージトラッキング機能がサポートされている場合にのみ、インスタンスでメッセージトラッキングをクエリできます。
説明ApsaraMQ for RabbitMQ インスタンスを作成するときに、インスタンスのメッセージトラッキング機能を有効にするかどうか、およびメッセージトラッキングをクエリする時間範囲を指定できます。 ApsaraMQ for RabbitMQ インスタンスでメッセージトラッキング機能が有効になっていない場合は、インスタンスの構成をアップグレードしてメッセージトラッキング機能を有効にすることができます。詳細については、「インスタンス構成のアップグレードまたはダウングレード」をご参照ください。
ローカル時間から過去 3 日間、7 日間、または 15 日間のメッセージトラッキングをクエリできます。
たとえば、ローカル時間から過去 3 日間のメッセージトラッキングをクエリできます。ローカル時間が 2022 年 4 月 12 日 10:45:18 の場合、クエリできる最も古いメッセージトラッキングは、2022 年 4 月 9 日 10:45:18 に生成されたものです。
前提条件
ApsaraMQ for RabbitMQ インスタンスでメッセージトラッキング機能が有効になっている。
ApsaraMQ for RabbitMQ インスタンスにメッセージが送信または消費されている。
手順
ApsaraMQ for RabbitMQ コンソール にログインします。左側のナビゲーションペインで、インスタンスリスト をクリックします。
インスタンスリスト ページの上部ナビゲーションバーで、管理するインスタンスが存在するリージョンを選択します。次に、インスタンスリストで、管理するインスタンスの名前をクリックします。
左側のナビゲーションペインで、メッセージトレース をクリックします。
メッセージトレース ページで、クエリするメッセージが属する vhost を選択し、ビジネス要件に基づいてクエリ方法を選択します。
キュー名による照会 タブで、クエリするメッセージが属するキューを選択し、[時間範囲] パラメーターを構成して、照会 をクリックします。
Message ID による照会 タブで、クエリするメッセージの ID を入力し、[時間範囲] パラメーターを構成して、照会 をクリックします。
メッセージ処理期間による照会 タブで、クエリするメッセージが属するキューを選択し、メッセージ処理時間を秒単位で入力し、[時間範囲] パラメーターを構成して、照会 をクリックします。
メッセージリストで、トレースをクエリするメッセージを見つけ、トレース詳細 を 操作 列でクリックします。
[メッセージトラッキングの詳細] ページで、メッセージトラッキングの詳細を表示します。
次の表に、メッセージトラッキングのパラメーターを示します。
セクション
パラメーター
説明
概要
Vhost
メッセージが属する vhost。
メッセージ ID
メッセージ ID。
生成の詳細
到着時刻
メッセージが ApsaraMQ for RabbitMQ インスタンスに到着した時点。
交換
メッセージが送信された ApsaraMQ for RabbitMQ exchange。
ルーティングキー
メッセージをキューにルーティングするために使用されたルーティングキー。
プロデューサー IP
プロデューサークライアントの IP アドレス。
プロデューサーアカウント
プロデューサーが ApsaraMQ for RabbitMQ インスタンスにメッセージを送信したときに使用された Alibaba Cloud アカウントまたは Resource Access Management (RAM) ユーザーの ID。
キューへの入力結果
なし
メッセージが配信された ApsaraMQ for RabbitMQ キューの名前。
配信の詳細
配信時刻
メッセージがキューに配信された時点。
コンシューマー IP
コンシューマークライアントの IP アドレス。
コンシューマーアカウント
ApsaraMQ for RabbitMQ インスタンスからメッセージが消費されたときに使用された Alibaba Cloud アカウントまたは RAM ユーザーの ID。
消費方法
メッセージが消費されたときに使用されたリクエストメソッド。詳細については、「請求ルール」の ピーク TPS をご参照ください。
autoAck
メッセージが消費された後に ACK が自動的に送信されたかどうかを示します。
deliveryTag
メッセージの配信に使用された序数。 ApsaraMQ for RabbitMQ インスタンスがコンシューマーにメッセージをプッシュすると、序数が自動的に生成されます。
consumerTag
コンシューマータグ。コンシューマータグは、コンシューマークライアントの一意の識別子です。コンシューマータグは、ApsaraMQ for RabbitMQ インスタンスのコンシューマークライアントコードで指定することも、ApsaraMQ for RabbitMQ ブローカーによって自動的に生成することもできます。
最終結果
メッセージ消費結果。
コンシューマー応答の詳細
応答時間
メッセージが配信された後にクライアントが ACK を送信した時点。
応答方法
メッセージが消費された後にクライアントが ACK を送信するために使用した方法。
応答パラメーター
メッセージが消費された後にクライアントが ACK を自動的に送信したかどうかを示します。
応答結果
メッセージが消費された後にクライアントが ACK を正常に送信したかどうかを示します。