rabbitmq_queue_backlog_rca
Rank backlogged RabbitMQ queues to identify root causes—unacked messages, consumer gaps, or rate mismatches—and get recommended actions.
Instructions
[READ] Rank backlogged queues and map each to a cause + action.
The flagship backlog RCA: flags queues over the backlog threshold and classifies each — no consumers attached, unacked pileup (consumers not acking), publish rate outpacing delivery, or residual backlog — plus global memory/disk watermark alarms that block every publisher via flow control. Every finding carries its numbers. Pass 'queues' (and optionally 'nodes') for pure analysis, or a target to pull live.
Args: vhost: Restrict the live pull to one vhost; omit for all. top: How many queue rows to return, deepest first (default 20). queues: Injected rows {name, vhost, messages, messagesReady, messagesUnacked, consumers, publishRate, deliverRate, state}. nodes: Injected node_health rows {name, memAlarm, diskAlarm, ...}. target: rabbitmq target name from config; omit for the default.
Returns dict: {queuesEvaluated, backloggedCount, globalFindings, queues:[{name, vhost, messages, consumers, cause, action, ...}], thresholds, note}.
Input Schema
| Name | Required | Description | Default |
|---|---|---|---|
| top | No | ||
| nodes | No | ||
| vhost | No | ||
| queues | No | ||
| target | No |