ApsaraMQ for RocketMQ：Kueri jejak pesan

Data jejak pesan

Dalam ApsaraMQ for RocketMQ, jejak lengkap pesan melibatkan produsen, broker, dan konsumen. Saat setiap peran memproses pesan, informasi terkait ditambahkan ke jejak. Informasi ini dapat digunakan untuk mendapatkan status pesan.

Catatan penggunaan

Setelah pesan dikirim, Anda dapat menanyakan jejak pesan berdasarkan atribut pesan di konsol ApsaraMQ for RocketMQ. Fitur ini berlaku untuk semua jenis pesan. Sebelum menggunakan fitur jejak pesan, perhatikan poin-poin berikut:

Rentang waktu untuk kueri jejak pesan

ApsaraMQ for RocketMQ memungkinkan Anda menanyakan jejak pesan yang diproduksi dalam rentang waktu 1 hari sebelum titik waktu saat ini. Misalnya, jika titik waktu saat ini adalah 15:09:48 pada 30 November 2023, Anda dapat menanyakan jejak pesan yang diproduksi dari 15:09:48 pada 29 November 2023 hingga 15:09:48 pada 30 November 2023.

Dampak status konsumsi terhadap hasil kueri

Versi SDK yang mendukung fitur jejak pesan

Prasyarat untuk menggunakan fitur jejak pesan yang ditingkatkan

Fitur jejak pesan yang ditingkatkan memungkinkan Anda melihat lebih banyak data jejak di konsol ApsaraMQ for RocketMQ dibandingkan dengan fitur dasar. Anda dapat menanyakan data jejak yang dihasilkan selama konsumsi pesan, serta data jejak pesan terjadwal, pesan tertunda, dan pesan transaksional. Untuk informasi tentang parameter yang dikembalikan dalam hasil kueri jejak, lihat Parameter.

• SDK Klien TCP untuk Java:

  • SDK Klien TCP untuk Java ditingkatkan ke V2.x.x.Final.

  • Instans harus diterapkan di salah satu wilayah berikut: Tiongkok (Hangzhou), Tiongkok (Qingdao), Tiongkok (Beijing), Tiongkok (Zhangjiakou), Tiongkok (Hohhot), Tiongkok (Shenzhen), Tiongkok (Chengdu), Jerman (Frankfurt), dan Indonesia (Jakarta).

• SDK Klien TCP untuk C++:

  • SDK Klien TCP untuk C++ ditingkatkan ke V3.x.x.

  • Instans dapat diterapkan di wilayah mana pun.

Skenario umum

Jika pesan tidak dikirim atau dikonsumsi sesuai harapan dalam lingkungan produksi, Anda dapat menggunakan fitur jejak pesan untuk mendiagnosis masalah. Anda dapat menanyakan jejak pesan berdasarkan ID pesan, kunci pesan, atau topik dalam rentang waktu tertentu untuk memeriksa apakah pesan dikirim atau dikonsumsi sesuai harapan.

Contoh

Jika Anda tidak menerima pesan sesuai harapan dan ingin mengidentifikasi penyebab berdasarkan log terkait, lakukan langkah-langkah berikut untuk mendiagnosis masalah menggunakan jejak pesan:

1. Kumpulkan informasi tentang pesan, termasuk ID pesan, kunci pesan, topik, dan perkiraan waktu pesan dikirim.

2. Masuk ke konsol ApsaraMQ for RocketMQ dan buat tugas kueri berdasarkan informasi yang dikumpulkan untuk menanyakan jejak pesan.

3. Periksa hasil kueri dan analisis penyebab.

   • Jika Not Consumed ditampilkan dalam jejak, Anda dapat pergi ke halaman Groups untuk memeriksa status konsumsi dan menentukan apakah masalah disebabkan oleh akumulasi pesan. Untuk informasi lebih lanjut, lihat Lihat Detail Konsumen.

   • Jika pesan dikonsumsi, periksa informasi konsumsi untuk menemukan klien konsumen yang sesuai dan waktu saat pesan dikonsumsi. Kemudian, masuk ke klien konsumen untuk melihat log terkait.

Prosedur

1. Masuk ke Konsol ApsaraMQ for RocketMQ. Di panel navigasi sisi kiri, klik Instances.

2. Di bilah navigasi atas, pilih wilayah, seperti China (Hangzhou). Di halaman Instans, klik nama instans yang ingin Anda kelola.

3. Di panel navigasi sisi kiri, klik Message Trace. Di pojok kiri atas halaman yang muncul, klik Create Query Task.

4. Di panel Create Message Trace Query Task, konfigurasikan kondisi kueri berdasarkan kebutuhan bisnis Anda. Lalu, klik OK.

   Penting

   Atur rentang waktu seakurat mungkin untuk mempersempit ruang lingkup kueri dan mempercepat proses kueri.

   Metode kueri berikut didukung oleh fitur jejak pesan:

   • Query by Message ID: Metode ini direkomendasikan karena pencocokan tepat dan kecepatannya yang cepat.

   • Query by Message Key: Metode ini menggunakan pencarian kabur. Jika Anda menggunakan metode ini, Anda dapat menanyakan jejak hingga 1.000 pesan. Metode ini hanya cocok untuk skenario di mana Anda tidak mencatat ID pesan tetapi menentukan kunci yang secara unik mengidentifikasi pesan.

   • Query by Topic: Metode ini menggunakan kueri rentang. Metode ini cocok untuk skenario volume pesan kecil di mana Anda tidak mencatat ID pesan atau menentukan kunci pesan. Kami menyarankan agar Anda tidak menggunakan metode kueri ini. Dalam kebanyakan kasus, sejumlah besar pesan dihasilkan dalam topik dalam rentang waktu tertentu. Jika Anda menggunakan metode ini, Anda hampir tidak dapat mengidentifikasi pesan tertentu di antara pesan yang dikueri.

   Setelah Anda membuat tugas kueri, Anda dapat melihat tugas kueri di halaman Message Trace. Jika Querying ditampilkan di kolom Status, jejak pesan tidak dapat dilihat. Anda dapat mengklik tombol di pojok kanan atas daftar tugas untuk menyegarkan status tugas sampai status tugas berubah menjadi Query Completed.

Parameter

Di halaman Jejak Pesan, temukan tugas kueri Anda dan klik Query Results di kolom Actions. Di halaman yang muncul, Anda dapat melihat status pengiriman dan status konsumsi pesan yang dikueri di kolom Sending Status dan Consumption Status. Anda juga dapat melihat status pengiriman dan status konsumsi setiap pesan di bagian Producer dan Consumer pada halaman detail jejak pesan. Tabel berikut menjelaskan kemungkinan status pengiriman dan konsumsi.

FAQ

Mengapa saya tidak dapat menanyakan jejak pesan?

• Periksa apakah versi SDK valid. Untuk informasi tentang versi SDK yang mendukung fitur jejak pesan, lihat Versi SDK yang Mendukung Fitur Jejak Pesan.

• Periksa apakah rentang waktu yang Anda tentukan valid.

  ApsaraMQ for RocketMQ memungkinkan Anda menanyakan jejak pesan yang diproduksi dalam waktu 1 hari sebelum titik waktu saat ini. Misalnya, jika titik waktu saat ini adalah 15:09:48 pada 30 November 2023, Anda dapat menanyakan jejak pesan yang diproduksi dari 15:09:48 pada 29 November 2023 hingga 15:09:48 pada 30 November 2023.

• Data jejak pesan mungkin tidak lengkap karena fitur jejak pesan diimplementasikan dalam tautan asinkron. Sistem mungkin tidak mengembalikan hasil untuk kueri meskipun kondisi kueri yang Anda tentukan valid. Dalam hal ini, Anda dapat menanyakan log di klien Anda untuk mendapatkan detail konsumsi. Untuk informasi lebih lanjut, lihat Pengaturan Logging.

Referensi

Anda juga dapat menanyakan jejak pesan dengan memanggil operasi API berikut yang disediakan oleh ApsaraMQ for RocketMQ:

• OnsTraceQueryByMsgId

• OnsTraceQueryByMsgKey

• OnsTraceGetResult