dom
/
telegraf
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

Add messages_delivered_get to rabbitmq_overview (#3596)

This commit is contained in:
kerams 2017-12-19 05:36:59 +01:00 committed by Daniel Nelson
parent 3029d58cad
commit 496452144c
2 changed files with 19 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
plugins/inputs/rabbitmq/README.md
View File

@ -52,6 +52,7 @@ For additional details reference the [RabbitMQ Management HTTP Stats](https://cd
- messages (int, messages) - messages (int, messages)
- messages_acked (int, messages) - messages_acked (int, messages)
- messages_delivered (int, messages) - messages_delivered (int, messages)
- messages_delivered_get (int, messages)
- messages_published (int, messages) - messages_published (int, messages)
- messages_ready (int, messages) - messages_ready (int, messages)
- messages_unacked (int, messages) - messages_unacked (int, messages)
@ -115,6 +116,12 @@ For additional details reference the [RabbitMQ Management HTTP Stats](https://cd
### Sample Queries: ### Sample Queries:
Message rates for the entire node can be calculated from total message counts. For instance, to get the rate of messages published per minute, use this query:
```
SELECT NON_NEGATIVE_DERIVATIVE(LAST("messages_published"), 1m) AS messages_published_rate
FROM rabbitmq_overview WHERE time > now() - 10m GROUP BY time(1m)
```
### Example Output: ### Example Output:

23
plugins/inputs/rabbitmq/rabbitmq.go
View File

@ -268,17 +268,18 @@ func gatherOverview(r *RabbitMQ, acc telegraf.Accumulator) {
tags["name"] = r.Name tags["name"] = r.Name
} }
fields := map[string]interface{}{ fields := map[string]interface{}{
"messages": overview.QueueTotals.Messages, "messages": overview.QueueTotals.Messages,
"messages_ready": overview.QueueTotals.MessagesReady, "messages_ready": overview.QueueTotals.MessagesReady,
"messages_unacked": overview.QueueTotals.MessagesUnacknowledged, "messages_unacked": overview.QueueTotals.MessagesUnacknowledged,
"channels": overview.ObjectTotals.Channels, "channels": overview.ObjectTotals.Channels,
"connections": overview.ObjectTotals.Connections, "connections": overview.ObjectTotals.Connections,
"consumers": overview.ObjectTotals.Consumers, "consumers": overview.ObjectTotals.Consumers,
"exchanges": overview.ObjectTotals.Exchanges, "exchanges": overview.ObjectTotals.Exchanges,
"queues": overview.ObjectTotals.Queues, "queues": overview.ObjectTotals.Queues,
"messages_acked": overview.MessageStats.Ack, "messages_acked": overview.MessageStats.Ack,
"messages_delivered": overview.MessageStats.Deliver, "messages_delivered": overview.MessageStats.Deliver,
"messages_published": overview.MessageStats.Publish, "messages_delivered_get": overview.MessageStats.DeliverGet,
"messages_published": overview.MessageStats.Publish,
} }
acc.AddFields("rabbitmq_overview", fields, tags) acc.AddFields("rabbitmq_overview", fields, tags)
} }