RabbitMQ Input Plugin

This plugin gathers statistics from RabbitMQ servers via the Management Plugin.

Introduced in: Telegraf v0.1.5 Tags: server OS support: all

Global configuration options

In addition to the plugin-specific configuration settings, plugins support additional global and plugin configuration settings. These settings are used to modify metrics, tags, and field or create aliases and configure ordering, etc. See the CONFIGURATION.md for more details.

Secret-store support

This plugin supports secrets from secret-stores for the username and password option. See the secret-store documentation for more details on how to use them.

Configuration

# Reads metrics from RabbitMQ servers via the Management Plugin
[[inputs.rabbitmq]]
  ## Management Plugin url. (default: http://localhost:15672)
  # url = "http://localhost:15672"

  ## Credentials
  # username = "guest"
  # password = "guest"

  ## Optional TLS Config
  # tls_ca = "/etc/telegraf/ca.pem"
  # tls_cert = "/etc/telegraf/cert.pem"
  # tls_key = "/etc/telegraf/key.pem"
  ## Use TLS but skip chain & host verification
  # insecure_skip_verify = false

  ## Optional request timeouts
  ##
  ## ResponseHeaderTimeout, if non-zero, specifies the amount of time to wait
  ## for a server's response headers after fully writing the request.
  # header_timeout = "3s"
  ##
  ## client_timeout specifies a time limit for requests made by this client.
  ## Includes connection time, any redirects, and reading the response body.
  # client_timeout = "4s"

  ## A list of nodes to gather as the rabbitmq_node measurement. If not
  ## specified, metrics for all nodes are gathered.
  # nodes = ["rabbit@node1", "rabbit@node2"]

  ## A list of exchanges to gather as the rabbitmq_exchange measurement. If not
  ## specified, metrics for all exchanges are gathered.
  # exchanges = ["telegraf"]

  ## Metrics to include and exclude. Globs accepted.
  ## Note that an empty array for both will include all metrics
  ## Currently the following metrics are supported: "exchange", "federation", "node", "overview", "queue"
  # metric_include = []
  # metric_exclude = []

  ## Queues to include and exclude. Globs accepted.
  ## Note that an empty array for both will include all queues
  # queue_name_include = []
  # queue_name_exclude = []

  ## Federation upstreams to include and exclude specified as an array of glob
  ## pattern strings.  Federation links can also be limited by the queue and
  ## exchange filters.
  # federation_upstream_include = []
  # federation_upstream_exclude = []

Metrics

• rabbitmq_overview

  • tags:
    • url
    • name
  • fields:
    • channels (int, channels)
    • connections (int, connections)
    • consumers (int, consumers)
    • exchanges (int, exchanges)
    • messages (int, messages)
    • messages_acked (int, messages)
    • messages_delivered (int, messages)
    • messages_delivered_get (int, messages)
    • messages_published (int, messages)
    • messages_ready (int, messages)
    • messages_unacked (int, messages)
    • queues (int, queues)
    • clustering_listeners (int, cluster nodes)
    • amqp_listeners (int, amqp nodes up)
    • return_unroutable (int, number of unroutable messages)
    • return_unroutable_rate (float, number of unroutable messages per second)

• rabbitmq_node

  • tags:
    • url
    • node
    • url
  • fields:
    • disk_free (int, bytes)
    • disk_free_limit (int, bytes)
    • disk_free_alarm (int, disk alarm)
    • fd_total (int, file descriptors)
    • fd_used (int, file descriptors)
    • mem_limit (int, bytes)
    • mem_used (int, bytes)
    • mem_alarm (int, memory a)
    • proc_total (int, erlang processes)
    • proc_used (int, erlang processes)
    • run_queue (int, erlang processes)
    • sockets_total (int, sockets)
    • sockets_used (int, sockets)
    • running (int, node up)
    • uptime (int, milliseconds)
    • mnesia_disk_tx_count (int, number of disk transaction)
    • mnesia_ram_tx_count (int, number of ram transaction)
    • mnesia_disk_tx_count_rate (float, number of disk transaction per second)
    • mnesia_ram_tx_count_rate (float, number of ram transaction per second)
    • gc_num (int, number of garbage collection)
    • gc_bytes_reclaimed (int, bytes)
    • gc_num_rate (float, number of garbage collection per second)
    • gc_bytes_reclaimed_rate (float, bytes per second)
    • io_read_avg_time (float, number of read operations)
    • io_read_avg_time_rate (int, number of read operations per second)
    • io_read_bytes (int, bytes)
    • io_read_bytes_rate (float, bytes per second)
    • io_write_avg_time (int, milliseconds)
    • io_write_avg_time_rate (float, milliseconds per second)
    • io_write_bytes (int, bytes)
    • io_write_bytes_rate (float, bytes per second)
    • mem_connection_readers (int, bytes)
    • mem_connection_writers (int, bytes)
    • mem_connection_channels (int, bytes)
    • mem_connection_other (int, bytes)
    • mem_queue_procs (int, bytes)
    • mem_queue_slave_procs (int, bytes)
    • mem_plugins (int, bytes)
    • mem_other_proc (int, bytes)
    • mem_metrics (int, bytes)
    • mem_mgmt_db (int, bytes)
    • mem_mnesia (int, bytes)
    • mem_other_ets (int, bytes)
    • mem_binary (int, bytes)
    • mem_msg_index (int, bytes)
    • mem_code (int, bytes)
    • mem_atom (int, bytes)
    • mem_other_system (int, bytes)
    • mem_allocated_unused (int, bytes)
    • mem_reserved_unallocated (int, bytes)
    • mem_total (int, bytes)

• rabbitmq_queue

  • tags:
    • url
    • queue
    • vhost
    • node
    • durable
    • auto_delete
  • fields:
    • consumer_utilisation (float, percent)
    • consumers (int, int)
    • idle_since (string, time - e.g., “2006-01-02 15:04:05”)
    • head_message_timestamp (int, unix timestamp - only emitted if available from API)
    • memory (int, bytes)
    • message_bytes (int, bytes)
    • message_bytes_persist (int, bytes)
    • message_bytes_ram (int, bytes)
    • message_bytes_ready (int, bytes)
    • message_bytes_unacked (int, bytes)
    • messages (int, count)
    • messages_ack (int, count)
    • messages_ack_rate (float, messages per second)
    • messages_deliver (int, count)
    • messages_deliver_rate (float, messages per second)
    • messages_deliver_get (int, count)
    • messages_deliver_get_rate (float, messages per second)
    • messages_publish (int, count)
    • messages_publish_rate (float, messages per second)
    • messages_ready (int, count)
    • messages_redeliver (int, count)
    • messages_redeliver_rate (float, messages per second)
    • messages_unack (int, count)
    • slave_nodes (int, count)
    • synchronised_slave_nodes (int, count)

• rabbitmq_exchange

  • tags:
    • url
    • exchange
    • type
    • vhost
    • internal
    • durable
    • auto_delete
  • fields:
    • messages_publish_in (int, count)
    • messages_publish_in_rate (int, messages per second)
    • messages_publish_out (int, count)
    • messages_publish_out_rate (int, messages per second)

• rabbitmq_federation

  • tags:
    • url
    • vhost
    • type
    • upstream
    • exchange
    • upstream_exchange
    • queue
    • upstream_queue
  • fields:
    • acks_uncommitted (int, count)
    • consumers (int, count)
    • messages_unacknowledged (int, count)
    • messages_uncommitted (int, count)
    • messages_unconfirmed (int, count)
    • messages_confirm (int, count)
    • messages_publish (int, count)
    • messages_return_unroutable (int, count)

Example Output

rabbitmq_queue,url=http://amqp.example.org:15672,queue=telegraf,vhost=influxdb,node=rabbit@amqp.example.org,durable=true,auto_delete=false,host=amqp.example.org head_message_timestamp=1493684017,messages_deliver_get=0i,messages_publish=329i,messages_publish_rate=0.2,messages_redeliver_rate=0,message_bytes_ready=0i,message_bytes_unacked=0i,messages_deliver=329i,messages_unack=0i,consumers=1i,idle_since="",messages=0i,messages_deliver_rate=0.2,messages_deliver_get_rate=0.2,messages_redeliver=0i,memory=43032i,message_bytes_ram=0i,messages_ack=329i,messages_ready=0i,messages_ack_rate=0.2,consumer_utilisation=1,message_bytes=0i,message_bytes_persist=0i 1493684035000000000
rabbitmq_overview,url=http://amqp.example.org:15672,host=amqp.example.org channels=2i,consumers=1i,exchanges=17i,messages_acked=329i,messages=0i,messages_ready=0i,messages_unacked=0i,connections=2i,queues=1i,messages_delivered=329i,messages_published=329i,clustering_listeners=2i,amqp_listeners=1i 1493684035000000000
rabbitmq_node,url=http://amqp.example.org:15672,node=rabbit@amqp.example.org,host=amqp.example.org fd_total=1024i,fd_used=32i,mem_limit=8363329126i,sockets_total=829i,disk_free=8175935488i,disk_free_limit=50000000i,mem_used=58771080i,proc_total=1048576i,proc_used=267i,run_queue=0i,sockets_used=2i,running=1i 149368403500000000
rabbitmq_exchange,url=http://amqp.example.org:15672,exchange=telegraf,type=fanout,vhost=influxdb,internal=false,durable=true,auto_delete=false,host=amqp.example.org messages_publish_in=2i,messages_publish_out=1i 149368403500000000