RabbitMQ redeliveries metrics?

IamaBase · January 17, 2020, 9:50pm

I notice that these used to be provided in the exchange metricset: https://github.com/elastic/beats/pull/6607/files/34b28f231537933ee1e0296393f6e726bc6d060d

But it appears they are not included as of 7.5.1. Is there a way to implement these?

Mario_Castro · January 21, 2020, 12:55pm

Hi @IamaBase

Sorry, when you say "these" what do you exactly mean? "exchanges" metricset has not suffer big changes recently so maybe it's something that has changed in your version of RabbitMQ. Which version of RabbitMQ are you using?

Thanks

IamaBase · January 27, 2020, 10:49pm

Sorry. I mean the metrics regarding redelivered messages. The RabbitMQ version is 3.6.10.

I am currently feeding them into our alert chain via DataDog. I can see metrics related to message redeliveries via /api/overview and /api/queues within the message_stats objects.

I think the DataDog Agent gets them here:

github.com

DataDog/integrations-core/blob/master/rabbitmq/datadog_checks/rabbitmq/rabbitmq.py#L46


    ('message_stats/deliver_get_details/rate', 'messages.deliver_get.rate', float),
    ('message_stats/publish', 'messages.publish.count', float),
    ('message_stats/publish_details/rate', 'messages.publish.rate', float),
    ('message_stats/publish_in', 'messages.publish_in.count', float),
    ('message_stats/publish_in_details/rate', 'messages.publish_in.rate', float),
    ('message_stats/publish_out', 'messages.publish_out.count', float),
    ('message_stats/publish_out_details/rate', 'messages.publish_out.rate', float),
    ('message_stats/return_unroutable', 'messages.return_unroutable.count', float),
    ('message_stats/return_unroutable_details/rate', 'messages.return_unroutable.rate', float),
    ('message_stats/redeliver', 'messages.redeliver.count', float),
    ('message_stats/redeliver_details/rate', 'messages.redeliver.rate', float),
]
QUEUE_ATTRIBUTES = [
    # Path, Name, Operation
    ('active_consumers', 'active_consumers', float),
    ('consumers', 'consumers', float),
    ('consumer_utilisation', 'consumer_utilisation', float),
    ('memory', 'memory', float),
    ('messages', 'messages', float),
    ('messages_details/rate', 'messages.rate', float),
    ('messages_ready', 'messages_ready', float),

github.com

DataDog/integrations-core/blob/master/rabbitmq/datadog_checks/rabbitmq/rabbitmq.py#L69


    ('messages_unacknowledged_details/rate', 'messages_unacknowledged.rate', float),
    ('message_stats/ack', 'messages.ack.count', float),
    ('message_stats/ack_details/rate', 'messages.ack.rate', float),
    ('message_stats/deliver', 'messages.deliver.count', float),
    ('message_stats/deliver_details/rate', 'messages.deliver.rate', float),
    ('message_stats/deliver_get', 'messages.deliver_get.count', float),
    ('message_stats/deliver_get_details/rate', 'messages.deliver_get.rate', float),
    ('message_stats/publish', 'messages.publish.count', float),
    ('message_stats/publish_details/rate', 'messages.publish.rate', float),
    ('message_stats/redeliver', 'messages.redeliver.count', float),
    ('message_stats/redeliver_details/rate', 'messages.redeliver.rate', float),
]


NODE_ATTRIBUTES = [
    ('fd_used', 'fd_used', float),
    ('disk_free', 'disk_free', float),
    ('mem_used', 'mem_used', float),
    ('mem_limit', 'mem_limit', float),
    ('run_queue', 'run_queue', float),
    ('sockets_used', 'sockets_used', float),
    ('partitions', 'partitions', len),

github.com

DataDog/integrations-core/blob/master/rabbitmq/datadog_checks/rabbitmq/rabbitmq.py#L111


    ('message_stats/deliver_get_details/rate', 'messages.deliver_get.rate', float),
    ('message_stats/publish', 'messages.publish.count', float),
    ('message_stats/publish_details/rate', 'messages.publish.rate', float),
    ('message_stats/publish_in', 'messages.publish_in.count', float),
    ('message_stats/publish_in_details/rate', 'messages.publish_in.rate', float),
    ('message_stats/publish_out', 'messages.publish_out.count', float),
    ('message_stats/publish_out_details/rate', 'messages.publish_out.rate', float),
    ('message_stats/return_unroutable', 'messages.return_unroutable.count', float),
    ('message_stats/return_unroutable_details/rate', 'messages.return_unroutable.rate', float),
    ('message_stats/redeliver', 'messages.redeliver.count', float),
    ('message_stats/redeliver_details/rate', 'messages.redeliver.rate', float),
]


ATTRIBUTES = {
    EXCHANGE_TYPE: EXCHANGE_ATTRIBUTES,
    QUEUE_TYPE: QUEUE_ATTRIBUTES,
    NODE_TYPE: NODE_ATTRIBUTES,
    OVERVIEW_TYPE: OVERVIEW_ATTRIBUTES,
}


TAG_PREFIX = 'rabbitmq'

system · February 24, 2020, 10:50pm

This topic was automatically closed 28 days after the last reply. New replies are no longer allowed.

Topic		Replies	Views
Metricbeat RabbitMQ collect message rates Beats	3	526	March 14, 2018
Rabbitmq plugin field problem Beats metricbeat	16	763	February 10, 2019
Metrics related to the Message Queue Beats metricbeat	2	344	April 23, 2018
How to monitor Publish and Delivery Rate of messages in RabbitMQ Queues using Metricbeat? Beats metricbeat	2	583	April 26, 2023
Metricbeat RabbitMQ module not sending all metric sets Beats metricbeat	6	748	September 13, 2018

RabbitMQ redeliveries metrics?

Related topics