RabbitMQ¶

·

RabbitMQ collector monitors RabbitMQ by collecting data through the plug-in rabbitmq-management and can:

• RabbitMQ overview, such as connections, queues, total messages, and so on.
• Track RabbitMQ queue information, such as queue size, consumer count and so on.
• Rack RabbitMQ node information, such as socket mem.
• Tracking RabbitMQ exchange information such as message_publish_count.

Configuration¶

Preconditions¶

• RabbitMQ version >= 3.8.14; Already tested version:

  • 3.11.x
  • 3.10.x
  • 3.9.x
  • 3.8.x

• Install rabbitmq, take Ubuntu as an example

  sudo apt-get update
  sudo apt-get install rabbitmq-server
  sudo service rabbitmq-server start
  

• Start REST API plug-ins

  sudo rabbitmq-plugins enable rabbitmq_management
  

• Create user, for example:

  sudo rabbitmqctl add_user guance <SECRET>
  sudo rabbitmqctl set_permissions  -p / guance "^aliveness-test$" "^amq\.default$" ".*"
  sudo rabbitmqctl set_user_tags guance monitoring
  

Collector Configuration¶

[[inputs.rabbitmq]]
  # rabbitmq url ,required
  url = "http://localhost:15672"

  # rabbitmq user, required
  username = "guest"

  # rabbitmq password, required
  password = "guest"

  # ##(optional) collection interval, default is 30s
  # interval = "30s"

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

  ## Set true to enable election
  election = true

  # [inputs.rabbitmq.log]
  # files = []
  # #grok pipeline script path
  # pipeline = "rabbitmq.p"

  [inputs.rabbitmq.tags]
  # some_tag = "some_value"
  # more_tag = "some_other_value"
  # ...

Metric¶

For all of the following data collections, a global tag named host is appended by default (the tag value is the host name of the DataKit), or other tags can be specified in the configuration by [inputs.rabbitmq.tags]:

 [inputs.rabbitmq.tags]
  # some_tag = "some_value"
  # more_tag = "some_other_value"
  # ...

rabbitmq_overview¶

• tag

• metric list

rabbitmq_queue¶

• tag

• metric list

rabbitmq_exchange¶

• tag

• metric list

rabbitmq_node¶

• tag

• metric list

Log Collection¶

To collect the RabbitMQ log, open files in RabbitMQ.conf and write to the absolute path of the RabbitMQ log file. For example:

    [[inputs.rabbitmq]]
      ...
      [inputs.rabbitmq.log]
        files = ["/var/log/rabbitmq/rabbit@your-hostname.log"]

When log collection is turned on, a log with a log source of rabbitmq is generated by default.

Log Pipeline Function Cut Field Description¶

• RabbitMQ universal log cutting

Example of common log text:

2021-05-26 14:20:06.105 [warning] <0.12897.46> rabbitmqctl node_health_check and its HTTP API counterpart are DEPRECATED. See https://www.rabbitmq.com/monitoring.html#health-checks for replacement options.

The list of cut fields is as follows: