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.