RabbitMQ 输入插件

此插件通过 Management Plugin 从 RabbitMQ 服务器收集统计信息。

引入于: Telegraf v0.1.5 标签: server 操作系统支持: all

全局配置选项

插件支持其他全局和插件配置设置，用于修改指标、标签和字段，创建别名以及配置插件顺序等任务。更多详情请参阅 CONFIGURATION.md。

Secret-store 支持

此插件支持从 secret-stores 获取 username 和 password 选项的密钥。有关如何使用它们的更多详细信息，请参阅 secret-store 文档。

配置

# Reads metrics from RabbitMQ servers via the Management Plugin
[[inputs.rabbitmq]]
  ## Management Plugin url. (default: https://:15672)
  # url = "https://: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 = []

  ## Include queue type as a tag. When enabled, adds a "type" tag to queue metrics
  ## with the queue type returned by RabbitMQ (e.g., "classic", "quorum", "stream").
  ## Defaults to "classic" if empty.
  # include_queue_type_tag = false

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
    • 节点
    • 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
    • 节点
    • durable
    • auto_delete
    • type (queue type as returned by RabbitMQ, if empty it defaults to “classic”; only included when include_queue_type_tag = true)
  • 字段 (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)
    • 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)

示例输出

rabbitmq_queue,url=http://amqp.example.org:15672,queue=telegraf,vhost=influxdb,node=rabbit@amqp.example.org,durable=true,auto_delete=false,type=classic,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