ApsaraMQ for RocketMQ hizmetleri için gerçek zamanlı bir istatistik panosu sağlamak amacıyla Application Real-Time Monitoring Service (ARMS) içindeki Managed Service for Prometheus ve Managed Service for Grafana'nın ölçüm depolama ve görselleştirme yeteneklerini kullanır. Bu özellik, işinizin operasyonel durumunu hızlıca anlamanıza olanak tanımak için ölçümleri toplamanızı ve izlemenizi sağlar. Bu konu, kullanım senaryolarını, faturalamayı, mevcut ölçümleri ve panonun nasıl kullanılacağını açıklar.
Kullanım Senaryoları
Mesaj tüketimindeki anormallikler için anında uyarılar alarak sorunları hızla tespit edip çözün ve mesajların zamanında işlenmesini sağlayın.
İş akışı boyunca mesaj iletiminin düzgün çalıştığını doğrulamak için mesaj izlemesini inceleyerek belirli siparişlerdeki (örneğin anormal durum) sorunları giderin.
Mesaj trafiği eğilimlerini, dağıtım kalıplarını ve toplam hacmi analiz ederek iş trendlerini tahmin edin ve kaynak planlaması yapın.
Uygulama bağımlılık topolojinizi görselleştirip analiz ederek yukarı ve aşağı akış bağımlılıklarını anlayın; bu sayede mimari yükseltmeler, optimizasyonlar ve yeniden yapılandırma planlamasını basitleştirin.
Ön Koşullar
-
Hizmet bağlantılı bir rol oluşturun.
Rol adı: AliyunServiceRoleForOns
Rol ilke adı: AliyunServiceRolePolicyForOns
İzin açıklaması: Message Queue for RocketMQ hizmetinin rolü üstlenmesine ve izleme, uyarı ve pano özellikleri için CloudMonitor ile ARMS'e erişmesine olanak tanır.
Ayrıntılar için bkz. Hizmet bağlantılı roller.
Faturalama
ApsaraMQ for RocketMQ için pano ölçümleri, Managed Service for Prometheus'taki temel ölçümlerdir. Bu ölçümler ücretsiz olduğundan pano özelliği de ücretsizdir.
Daha fazla bilgi için bkz. Ölçümler ve Kullandıkça öde.
Temel Kavramlar
Pano ölçümlerini görüntülemeden önce tüketici gecikmesiyle ilgili aşağıdaki kavramları anlamanız gerekir.
Yukarıdaki şekil, belirli bir konu için bir kuyruktaki mesajların durumunu gösterir. Message Queue for RocketMQ farklı aşamalardaki mesaj sayısı ve işleme süresi hakkında istatistik toplar. Bu ölçümler, mesaj işleme hızını ve tüketici gecikmesini doğrudan yansıtır. Bu ölçümlerin izlenmesi, mesaj tüketimindeki potansiyel anormallikleri hızlıca belirlemenize yardımcı olur.
Kategori | Ölçüm | Açıklama | Hesaplama formülü |
Mesaj sayısı ölçümleri | işlemdeki mesajlar | Tüketici istemcilerinin işlediği ancak henüz onaylanmamış mesajlar. | en son çekilen mesajın ofseti - en son işlenen mesajın ofseti |
hazır mesajlar | Message Queue for RocketMQ sunucusunda tüketime hazır olan mesajlar. | Maksimum mesaj ofseti - en son çekilen mesajın ofseti | |
tüketici gecikmesi | İşlenmemiş toplam mesaj sayısı. | İşlemdeki mesaj sayısı + Hazır mesaj sayısı | |
Mesaj gecikmesi ölçümleri | hazır olma zamanı |
| Geçerli değil |
hazır mesaj kuyruk süresi | Mevcut zaman ile en eski hazır mesajın hazır olma zamanı arasındaki fark. Bu ölçüm, tüketicilerin mesajları ne kadar hızlı çektiğini gösterir. | Mevcut zaman - En eski hazır mesajın hazır olma zamanı | |
tüketici gecikme süresi | Mevcut zaman ile onaylanmamış en eski mesajın hazır olma zamanı arasındaki fark. Bu ölçüm, tüketicilerin mesajları ne kadar hızlı işlediğini gösterir. | Mevcut zaman - Onaylanmamış en eski mesajın hazır olma zamanı |
Ölçümler
Message Queue for Apache RocketMQ panosu aşağıdaki ölçümleri sağlar:
Üretici: Gönderilen mesaj sayısı, gönderme başarı oranı ve mesaj gönderme yanıt süresi gibi bir konuya ait ölçümleri görüntüleyin.
Tüketici: Alınan mesaj sayısı, tüketim başarı oranı ve tüketici gecikmesi gibi bir grubun belirli bir konuya aboneliğiyle ilgili ölçümleri görüntüleyin.
Örnek en iyi 20 genel bakış: Bir örnek içindeki belirli ölçümler için en yüksek 20 değeri ve bunlara karşılık gelen konu veya grubu görüntüleyin.
Faturalama ölçümü genel bakışı: Gönderme ve alma TPS'si, API çağrı sayısı ve ortalama mesaj boyutu gibi belirli bir örneğe ait ölçümleri görüntüleyin. Bu ölçümler faturalama maliyetlerini tahmin etmenize yardımcı olabilir.
Tüm ölçümler 1 dakikalık aralıklarla toplanır. Message Queue for Apache RocketMQ'da son 15 güne ait verileri sorgulayabilirsiniz. Tek bir sorgu için maksimum zaman aralığı 24 saattir.
Üretici
Ölçüm | Açıklama |
Mesaj gönderme hızı | Bir konuya gönderilen mesajların ve yapılan API çağrılarının hızı. Birimler:
|
Maksimum mesaj gönderme hızı | Maksimum mesaj gönderme hızı. Birim: mesaj/saniye. |
Toplam gönderilen mesajlar | Belirtilen örnekte gönderilen toplam mesaj sayısı. Birim: mesaj. |
Mesaj gönderme API çağrı başarı oranı | Bir konuya mesaj göndermek için yapılan API çağrılarının başarılı olma yüzdesi. |
Mesaj gönderme yanıt süresi | Bir konuya mesaj göndermek için geçen süre. Birim: ms. |
Tüketici
Ölçüm | Açıklama |
Ortalama tüketim başarı oranı | Bir grup tarafından başarıyla tüketilen mesajların yüzdesi. |
Tüketici gecikmesi (hazır + işlemde) | Bir grup için bekleyen toplam mesaj sayısı. Birim: mesaj. |
İşlemdeki mesajlar | Tüketici istemcilerine teslim edilen ancak henüz onaylanmamış mesajların sayısı. Birim: mesaj. |
Hazır mesajlar | Message Queue for Apache RocketMQ sunucusunda tüketime hazır olan mesajların sayısı. Bu ölçüm, tüketicilerin henüz işlemeye başlamadığı mesaj hacmini gösterir. Birim: mesaj. |
Hazır mesaj kuyruk süresi | En eski hazır mesajın tüketime hazır hale gelmesinden bu yana geçen süre. Bu ölçüm, mesaj işleme gecikmelerinin önemli bir göstergesidir ve zamana duyarlı uygulamalar için kritiktir. Genel bakış değeri, örnek için ortalama hazır mesaj kuyruk süresini gösterirken grafik, belirli bir konuya abone olan belirli bir grup için hazır mesaj kuyruk süresini gösterir. Birim: ms. |
Mesaj alma hızı | Bir grubun mesajları tüketme hızı. Birim: mesaj/saniye |
Maksimum mesaj alma hızı | Maksimum mesaj tüketim hızı. Birim: mesaj/saniye |
Toplam alınan mesajlar | Bir grup tarafından tüketilen toplam mesaj sayısı. Birim: mesaj. |
Tüketici gecikmesi | Bir grup için bekleyen mesaj sayısı. Bu, hem hazır mesajları hem de işlemdeki mesajları içerir. Birim: mesaj. |
Mesaj işleme süresi | Bir grubun bir mesajı işlemesi için geçen süre (tüketimin başlamasından tamamlanmasına kadar). Birim: ms. |
Tüketici tarafı bekleme süresi | Bir mesajın tüketici istemcisine ulaşmasından tüketimin başlamasına kadar geçen süre. Birim: ms. |
Tüketim başarı oranı | Mesaj tüketiminin başarı oranı. |
Tüketici istemci protokol oranı | Her bir istemci protokolü tarafından tüketilen mesajların oranı. |
Örnek En İyi 20
|
|
|
|
|
Mesaj gönderme hızı en yüksek olan ilk 20 konu. Birim: mesaj/saniye. |
|
|
Mesaj tüketim hızı en yüksek olan ilk 20 grup. Birim: mesaj/saniye. |
|
|
En fazla hazır mesaja sahip ilk 20 grup. Birim: mesaj. |
|
|
En uzun hazır mesaj kuyruk süresine sahip ilk 20 grup. Birim: ms. |
|
|
En büyük tüketici gecikmesine sahip ilk 20 grup. Birim: mesaj. |
Faturalama ölçümleri
Aşağıdaki faturalama ölçümleri, büyük mesajlar ve gelişmiş özellikler için çarpanları dikkate alır.
Büyük mesaj çarpanı: Her 4 KB'lık mesaj boyutu için bir API çağrısı sayılır. Örneğin, 16 KB'lık bir mesaj göndermek dört API çağrısı olarak sayılır (16 KB / 4 KB = 4).
Gelişmiş özellik mesaj çarpanı: Sıralı, zamanlanmış/gecikmeli ve işlemsel mesajlar gibi gelişmiş özelliklere yönelik API çağrıları, normal mesajlara kıyasla beş katı oranında sayılır.
|
|
|
|
|
Mesaj üretimi için maksimum saniye başına işlem (TPS). Bu ölçüm, örneğiniz için gereken maksimum TPS teknik özelliklerini tahmin etmenize yardımcı olur. Birim: TPS. |
|
|
Mesaj tüketimi için maksimum TPS. Bu ölçüm, örneğiniz için gereken maksimum TPS teknik özelliklerini tahmin etmenize yardımcı olur. Birim: TPS. |
|
|
Hem mesaj üretimi hem de tüketimi için toplam maksimum TPS. Bu ölçüm, örneğiniz için gereken maksimum TPS teknik özelliklerini tahmin etmenize yardımcı olur. Birim: TPS. |
|
|
Toplam API çağrısı sayısı. Bu ölçüm, faturalama amaçlı API çağrısı kullanımını tahmin etmenize yardımcı olur. Birim: çağrı. |
|
|
Üretilen tüm mesajların ortalama boyutu. Birim: bayt. |
|
|
Hem mesaj üretimi hem de tüketimi için toplam TPS. Birim: TPS. |
|
|
Hem mesaj üretimi hem de tüketimi için günlük toplam API çağrıları. Birim: çağrı. |
Ölçümler
Tüm mesaj aktarım hızı (TPS), istek ve mesaj sayısı ölçümleri 4 KB'lık normal bir mesajı temel alır. Nihai değer, gerçek mesaj boyutuna ve gelişmiş mesaj türüne göre faktörlerle çarpılır.
Aşağıdaki tabloda ölçümlerdeki alanlar açıklanmaktadır.
Alan | Değer |
Ölçüm türü | Gauge: Artabilen veya azalabilen bir ölçüm. API çağrılarının TPS'si gibi anlık bir ölçümü temsil eder. |
Etiket |
|
Sunucu tarafı ölçümleri
Ölçüm türü | Ölçüm adı | Birim | Açıklama | Etiket |
Gauge | rocketmq_instance_requests_threshold | count/s | Örnek için hız sınırlama eşiği. |
|
Gauge | rocketmq_instance_requests_max | count/s | Hız sınırına takılan istekler hariç, örneğin maksimum saniye başına işlem (TPS) değeri. Bu değer, bir dakikalık aralıkta kaydedilen tepe TPS değeridir. |
|
Üretici ölçümleri
Ölçüm türü | Ölçüm adı | Birim | Açıklama | Etiket |
Gauge | rocketmq_producer_requests (Faturalandırılabilir ölçüm) | count | Mesaj göndermek için faturalandırılabilir API çağrılarının sayısı. |
|
Gauge | rocketmq_producer_messages | message | Gönderilen mesaj sayısı. |
|
Gauge | rocketmq_producer_message_size_bytes | byte | Gönderilen mesajların toplam boyutu. |
|
Gauge | rocketmq_producer_send_success_rate | % | Mesaj gönderme başarı oranı. |
|
Gauge | rocketmq_producer_failure_api_calls | count | Mesaj göndermek için başarısız olan API çağrılarının sayısı. |
|
Gauge | rocketmq_producer_send_rt_milliseconds_avg | ms | Mesaj gönderme için ortalama yanıt süresi. |
|
Gauge | rocketmq_producer_send_rt_milliseconds_min | ms | Mesaj gönderme için minimum yanıt süresi. |
|
Gauge | rocketmq_producer_send_rt_milliseconds_max | ms | Mesaj gönderme için maksimum yanıt süresi. |
|
Gauge | rocketmq_producer_send_rt_milliseconds_p95 | ms | Mesaj gönderme yanıt süresinin %95'lik dilimi. |
|
Gauge | rocketmq_producer_send_rt_milliseconds_p99 | ms | Mesaj gönderme yanıt süresinin %99'luk dilimi. |
|
Tüketici ölçümleri
Ölçüm türü | Ölçüm adı | Birim | Açıklama | Etiket |
Gauge | rocketmq_consumer_requests | count | Mesaj tüketmek için yapılan API çağrılarının sayısı. |
|
Gauge | rocketmq_consumer_send_back_requests | count | Tüketim hatası sonrası mesajları geri göndermek için yapılan API çağrılarının sayısı. |
|
Gauge | rocketmq_consumer_send_back_messages | message | Tüketim hatası sonrası geri gönderilen mesaj sayısı. |
|
Gauge | rocketmq_consumer_messages | message | Tüketilen mesaj sayısı. |
|
Gauge | rocketmq_consumer_message_size_bytes | byte | Tüketilen mesajların toplam boyutu. |
|
Gauge | rocketmq_consumer_ready_and_inflight_messages | message | Hazır mesajlar ve işlemdeki mesajların toplamı olarak hesaplanan toplam tüketici gecikmesi. |
|
Gauge | rocketmq_consumer_ready_messages | message | Tüketiciler tarafından çekilmeyi bekleyen kuyruktaki mesaj sayısı. Hesaplama yöntemi: |
|
Gauge | rocketmq_consumer_inflight_messages | message | Tüketiciler tarafından çekilen ancak henüz onaylanmamış mesaj sayısı. Hesaplama yöntemi: |
|
Gauge | rocketmq_consumer_queue_time_milliseconds | ms | Mesaj kuyruk süresi. |
|
Gauge | rocketmq_consumer_message_await_time_milliseconds_avg | ms | Bir mesajın işlenmeden önce tüketici istemcisinin arabelleğinde beklediği ortalama süre. |
|
Gauge | rocketmq_consumer_message_await_time_milliseconds_min | ms | Bir mesajın işlenmeden önce tüketici istemcisinin arabelleğinde beklediği minimum süre. |
|
Gauge | rocketmq_consumer_message_await_time_milliseconds_max | ms | Bir mesajın işlenmeden önce tüketici istemcisinin arabelleğinde beklediği maksimum süre. |
|
Gauge | rocketmq_consumer_message_await_time_milliseconds_p95 | ms | Bir mesajın işlenmeden önce tüketici istemcisinin arabelleğinde beklediği sürenin %95'lik dilimi. |
|
Gauge | rocketmq_consumer_message_await_time_milliseconds_p99 | ms | Bir mesajın işlenmeden önce tüketici istemcisinin arabelleğinde beklediği sürenin %99'luk dilimi. |
|
Gauge | rocketmq_consumer_message_process_time_milliseconds_avg | ms | Bir tüketicinin bir mesajı işlemesi için harcadığı ortalama süre. |
|
Gauge | rocketmq_consumer_message_process_time_milliseconds_min | ms | Bir tüketicinin bir mesajı işlemesi için harcadığı minimum süre. |
|
Gauge | rocketmq_consumer_message_process_time_milliseconds_max | ms | Bir tüketicinin bir mesajı işlemesi için harcadığı maksimum süre. |
|
Gauge | rocketmq_consumer_message_process_time_milliseconds_p95 | ms | Mesaj işleme süresinin %95'lik dilimi. |
|
Gauge | rocketmq_consumer_message_process_time_milliseconds_p99 | ms | Mesaj işleme süresinin %99'luk dilimi. |
|
Gauge | rocketmq_consumer_consume_success_rate | % | Mesaj tüketim başarı oranı. |
|
Gauge | rocketmq_consumer_failure_api_calls | count | Mesaj tüketmek için başarısız olan API çağrılarının sayısı. |
|
Gauge | rocketmq_consumer_to_dlq_messages | message | Ölü mektup kuyruğuna gönderilen mesaj sayısı. |
|
Pano
Message Queue for Apache RocketMQ konsolunda oturum açın. Sol gezinme bölmesinden Instances seçeneğine tıklayın.
Üst menü çubuğunda China (Hangzhou) gibi bir bölge seçin. Ardından örnek listesinde hedef örneğe tıklayın.
-
Panoyu aşağıdaki yollardan herhangi biriyle görüntüleyebilirsiniz:
Instance Details sayfası: Instance Details sayfasında Dashboard sekmesine tıklayın.
Dashboard sekmesi: Sol gezinme bölmesinde Dashboard seçeneğine tıklayın.
Topic Details sayfası: Sol gezinme bölmesinden Topics seçeneğine tıklayın. Konu listesinde hedef konuya tıklayın. Topic Details sayfasında Topic Overview sekmesine tıklayın.
Group Details sayfası: Sol gezinme bölmesinden Groups seçeneğine tıklayın. Grup listesinde hedef gruba tıklayın. Group Details sayfasında Group Overview sekmesine tıklayın.
Pano SSS
Pano ölçüm verilerine erişim
Kök hesabınızı kullanarak ARMS konsolunda oturum açın.
Sol gezinme bölmesinde Access Center seçeneğine tıklayın.
Access Center sayfasında arama kutusuna
RocketMQyazın ve arama simgesine tıklayın.Arama sonuçlarında entegre etmek istediğiniz cloud hizmetini (örneğin Alibaba Cloud Message Queue for RocketMQ) seçin. Entegrasyon prosedürü hakkında daha fazla bilgi için bkz. Adım 1: Bir cloud hizmetinden izleme verilerini entegre etme.
Entegrasyon başarılı olduktan sonra sol gezinme bölmesinde Integration Management seçeneğine tıklayın.
Cloud Service Environment listesinde, ayrıntılar sayfasını açmak için hedef ortamın adına tıklayın.
Component Management sekmesinde, Basic Information bölümünde Prometheus instance yanındaki cloud hizmeti bölgesine tıklayın.
Bu sayfa verilere erişmek için farklı yöntemler sağlar.{key, select, RAM {RAM} Overview {Overview} Identities {Identities} Users {Users} Groups {Groups} Roles {Roles} Settings {Settings} Permissions {Permissions} Grants {Grants} Troubleshoot {Troubleshooting} Policies {Policies} Integrations {Integrations} Providers {SSO} Applications {OAuth (Preview)} CloudSSO {CloudSSO} AccessAnalyzing {Access Analysis} Analyzers {Analyzers} Findings {Findings} Beta {Beta} Governance {Cloud Governance} AgentControl {Agent Management} other {{key}} }
Verileri kendi yönettiğiniz Grafana'ya aktarma
Alibaba Cloud Message Queue for RocketMQ için tüm ölçüm verileri Alibaba Cloud Prometheus Service'inizde depolanır. Cloud hizmetini entegre etmek ve ortam adını ile HTTP API uç noktasını almak için Pano ölçüm verilerini nasıl elde ederim? bölümündeki adımları izleyin. Ardından, bu verileri kendi yönettiğiniz Grafana'ya aktarmak için API'yi kullanın. Daha fazla bilgi için bkz. Prometheus verilerine erişmek için Grafana'ya veya kendi yönettiğiniz bir uygulamaya bağlanmak üzere HTTP API uç noktası kullanma.
Ortalama ve Maksimum TPS
ortalama TPS = 1 dakikalık bir dönemdeki toplam istek sayısı / 60 saniye
maksimum TPS: Sistem, 1 dakikalık bir dönemde TPS değerini saniyede bir kez örnekler. Maksimum TPS, 60 örnekleme arasındaki en yüksek değerdir.
Örneğin:
Bir örneğin bir dakika içinde 60 mesaj ürettiğini varsayalım (tümü 4 KB'lık normal mesajlardır).
örneğin ortalama TPS'si = 60 istek / 60 saniye = 1 istek/saniye
Örneğin maksimum TPS'si aşağıdaki şekilde hesaplanır:
-
Tüm 60 mesaj ilk saniye içinde gönderilirse, o dakikanın her saniyesi için TPS değerleri 60, 0, 0, ..., 0 şeklinde olur.
Örneğin maksimum TPS'si 60 istek/saniyedir.
-
İlk saniyede 40 mesaj ve ikinci saniyede 20 mesaj gönderilirse, o dakikanın her saniyesi için TPS değerleri 40, 20, 0, 0, ..., 0 şeklinde olur.
Örneğin maksimum TPS'si 40 istek/saniyedir.