本文為您介紹如何查詢雲訊息佇列 RabbitMQ 版的執行個體TPS峰值。
背景資訊
當您實際使用的TPS流量峰值超過執行個體的TPS規格上限時,雲訊息佇列 RabbitMQ 版執行個體會被限流。
為了避免執行個體限流造成的業務影響,建議您在日常營運任務中將執行個體TPS峰值作為重點監控指標,提前預警規格超限風險,您也可以通過觀察執行個體TPS峰值的變化瞭解業務波動情況,判斷當前執行個體規格是否滿足業務需求。
查詢方式
雲訊息佇列 RabbitMQ 版支援以下幾種方式查詢執行個體TPS峰值。
|
查詢方式 |
說明 |
查詢時間層級 |
查詢資源層級 |
|
優勢:
|
分鐘級TPS峰值 取值為1分鐘周期內,每秒鐘執行個體TPS的最大值。 |
執行個體層級TPS峰值 |
|
|
秒級TPS峰值 |
|
|
|
秒級TPS峰值 |
執行個體層級TPS峰值 |
通過CloudMonitor查詢執行個體TPS峰值並設定警示
查詢執行個體TPS峰值
登入雲訊息佇列 RabbitMQ 版控制台,然後在左側導覽列選擇实例列表。
在实例列表頁面的頂部功能表列選擇地區,然後在執行個體列表中,單擊目標執行個體名稱。
-
在左側導覽列單擊监控指标。
-
在监控指标頁面,在分組列表中選擇資源類型為Instance,並選取查詢時間範圍。
指定執行個體TPS峰值查詢樣本如下:

設定API TPS峰值警示
登入雲訊息佇列 RabbitMQ 版控制台,然後在左側導覽列選擇实例列表。
在实例列表頁面的頂部功能表列選擇地區,然後在執行個體列表中,單擊目標執行個體名稱。
-
在左側導覽列單擊监控指标。
-
在监控指标頁面右上方,單擊建立警示規則。
頁面跳轉至CloudMonitor的建立警示規則面板。
-
在設定規則描述面板中,設定警示規則,從監控指標列表選擇為。具體操作,請參見警示服務。
通過執行個體詳情查詢執行個體TPS峰值
登入雲訊息佇列 RabbitMQ 版控制台,然後在左側導覽列選擇实例列表。
在实例列表頁面的頂部功能表列選擇地區,然後在執行個體列表中,單擊目標執行個體名稱。
-
在实例详情頁面單擊TPS峰值查询頁簽。
說明該方式最長可查詢15天範圍內的TPS峰值資料,因為查詢結果是秒級資料,為避免顯示資料過多,查詢結果只顯示10分鐘的資料結果。
當您發現 TPS 飆高時段的監控資料與預期不符,或出現無資料的情況時,通常是由於監控統計粒度差異導致的:查詢時間範圍較大(如 24 小時)時,系統以平均值展示資料,可能掩蓋短時峰值;查詢時間範圍較小(如 3 小時以內)時,資料更精確,更接近秒級 TPS 峰值的真實值。
建議您在排查 TPS 異常時,縮小查詢時間範圍至飆高時段附近(例如選擇 10 分鐘或更短的時間視窗),以擷取準確的秒級 TPS 峰值資料。
-
查詢執行個體層級TPS峰值:
單擊按实例级别查询頁簽,選取查詢時間,然後單擊查詢。

-
查詢API層級TPS峰值:
單擊按API级别查询頁簽,選取查詢時間,然後單擊查詢。

-
通過日誌查詢執行個體TPS峰值
具體操作,請參見查詢與分析快速指引。
分析語句樣本如下:
(Action : ConnectionOpen or Action : ChannelOpen or Action: ExchangeDeclare or Action: QueueBind or Action : QueueDeclare or Action : QueueDelete or Action : ExchangeDelete or Action : QueueUnBind or Action : ExchangeBind or Action : ExchangeUnBind or Action : BasicConsume or Action : BasicReject or Action : BasicRecover or Action : SendMessage or Action : BasicAck or Action : BasicNack or Action : BasicGet ) | select from_unixtime(cast(microtime as bigint)/1000/1000) as time, COUNT(*) as count GROUP by time ORDER by time limit 90000000
常見問題
為什麼不同時段訊息消費耗時差異顯著(如早上快下午慢)?
該現象通常並非雲訊息佇列 RabbitMQ 版系統分發延遲導致,而是由以下原因引起:
-
業務高峰期訊息積壓:高峰時段訊息發送速率超過消費者的處理能力,導致隊列積壓,消費端處理延遲隨之增大。
-
消費端 ACK 處理較慢:消費端對每條訊息的 ACK 響應處理耗時較長,拖慢了整體消費速度。
建議您採取以下最佳化措施:
-
適當增加消費者用戶端數量,以提升並發消費能力,縮短隊列積壓時間長度。
-
最佳化 ACK 處理邏輯,縮短單條訊息的處理時延。
以上問題屬於業務消費效能問題,與執行個體 TPS 峰值超限(限流)無關。若需確認是否為執行個體 TPS 峰值超限導致的限流,請參考本文中介紹的 TPS 峰值查詢方法,確認當前執行個體 TPS 峰值是否超過規格上限。