A fluent plugin that instruments metrics from records and exposes them via web interface. Intended to be used together with a Prometheus server.

If you are using Fluentd v0.10, you have to explicitly install fluent-plugin-record-reformer together. With Fluentd v0.12 or v0.14, there is no additional dependency.

Add this line to your application's Gemfile:

gem 'fluent-plugin-prometheus'

And then execute:

$ bundle

Or install it yourself as:

$ gem install fluent-plugin-prometheus

fluentd-plugin-prometheus includes 4 plugins.

• prometheus input plugin
• prometheus_monitor input plugin
• prometheus output plugin
• prometheus filter plugin

See sample configuration, or try tutorial.

You have to configure this plugin to expose metrics collected by other promtheus plugins. This plugin provides a metrics HTTP endpoint to be scraped by a prometheus server on 24231/tcp(default).

With following configuration, you can access http://localhost:24231/metrics on a server where fluentd running.

<source>
  type prometheus
</source>

More configuration parameters:

• bind: binding interface (default: '0.0.0.0')
• port: listen port (defaut: 24231)
• metrics_path: metrics HTTP endpoint (default: /metrics)

This plugin collects internal metrics in Fluentd. The metrics are similar to/part of monitor_agent.

Current exposed metrics:

• buffere_queue_length of each BufferedOutput plugins
• buffer_total_queued_size of each BufferedOutput plugins
• retry_count of each BufferedOutput plugins

With following configuration, those metrics are collected.

More configuration parameters:

• <labels>: additional labels for this metric (optional). See Labels
• interval: interval to update monitor_agent information in seconds (default: 5)

Both output/filter plugins instrument metrics from records. Both plugins have no impact against values of each records, just read.

Assuming you have following configuration and receiving message,

<match message>
  type stdout
</match>

message {
  "foo": 100,
  "bar": 200,
  "baz": 300
}

In filter plugin style,

<filter message>
  type prometheus
  <metric>
    name message_foo_counter
    type counter
    desc The total number of foo in message.
    key foo
  </metric>
</filter>

<match message>
  type stdout
</match>

In output plugin style:

<filter message>
  type prometheus
  <metric>
    name message_foo_counter
    type counter
    desc The total number of foo in message.
    key foo
  </metric>
</filter>

<match message>
  type copy
  <store>
    type prometheus
    <metric>
      name message_foo_counter
      type counter
      desc The total number of foo in message.
      key foo
    </metric>
  </store>
  <store>
    type stdout
  </store>
</match>

With above configuration, the plugin collects a metric named message_foo_counter from key foo of each records.

See Supported Metric Type and Labels for more configuration parameters.

For details of each metric type, see Prometheus documentation. Also see metric name guide.

<metric>
  name message_foo_counter
  type counter
  desc The total number of foo in message.
  key foo
  <labels>
    tag ${tag}
    host ${hostname}
    foo bar
  </labels>
</metric>

• name: metric name (required)
• type: metric type (required)
• desc: description of this metric (required)
• key: key name of record for instrumentation (optional)
• <labels>: additional labels for this metric (optional). See Labels

If key is empty, the metric values is treated as 1, so the counter increments by 1 on each record regardless of contents of the record.

<metric>
  name message_foo_gauge
  type gauge
  desc The total number of foo in message.
  key foo
  <labels>
    tag ${tag}
    host ${hostname}
    foo bar
  </labels>
</metric>

• name: metric name (required)
• type: metric type (required)
• desc: description of metric (required)
• key: key name of record for instrumentation (required)
• <labels>: additional labels for this metric (optional). See Labels

<metric>
  name message_foo
  type summary
  desc The summary of foo in message.
  key foo
  <labels>
    tag ${tag}
    host ${hostname}
    foo bar
  </labels>
</metric>

• name: metric name (required)
• type: metric type (required)
• desc: description of metric (required)
• key: key name of record for instrumentation (required)
• <labels>: additional labels for this metric (optional). See Labels

See Prometheus Data Model first.

You can add labels with static value or dynamic value from records. In prometheus_monitor input plugin, you can't use label value from records.

<labels>
  key1 value1
  key2 value2
</labels>

All labels sections has same format. Each lines have key/value for label.

You can use placeholder for label values. The placeholders will be expanded from records or reserved values. If you specify ${foo}, it will be expanded by value of foo in record.

Reserved placeholders are:

• ${hostname}: hostname
• ${tag}: tag name

Prometheus output/filter plugin can have multiple metric section. Top-level labels section spcifies labels for all metrics. Labels section insede metric section specifis labels for the metric. Both are specified, labels are merged.

<filter message>
  type prometheus
  <metric>
    name message_foo_counter
    type counter
    desc The total number of foo in message.
    key foo
    <labels>
      key foo
      data_type ${type}
    </labels>
  </metric>
  <metric>
    name message_bar_counter
    type counter
    desc The total number of bar in message.
    key bar
    <labels>
      key bar
    </labels>
  </metric>
  <labels>
    tag ${tag}
    hostname ${hostname}
  </labels>
</filter>

In this case, message_foo_counter has tag, hostname, key and data_type labels.

Checkout repository and setup.

$ git clone git://github.com/kazegusuri/fluent-plugin-prometheus
$ cd fluent-plugin-prometheus
$ bundle install --path vendor/bundle

Download pre-compiled prometheus binary and start it. It listens on 9090.

$ wget https://github.com/prometheus/prometheus/releases/download/0.16.1/prometheus-0.16.1.linux-amd64.tar.gz -O - | tar zxf -
$ ./prometheus-0.16.1.linux-amd64/prometheus -config.file=./misc/prometheus.yaml -storage.local.path=./prometheus/metrics

Install Nginx for sample metrics. It listens on 80 and 9999.

$ sudo apt-get install -y nginx
$ sudo cp misc/nginx_proxy.conf /etc/nginx/sites-enabled/proxy
$ sudo chmod 777 /var/log/nginx && sudo chmod +r /var/log/nginx/*.log
$ sudo service nginx restart

Start fluentd with sample configuration. It listens on 24231.

$ bundle exec fluentd -c misc/fluentd_sample.conf -v

Generate some records by accessing nginx.

$ curl http://localhost/
$ curl http://localhost:9999/

Confirm that some metrics are exported via Fluentd.

$ curl http://localhost:24231/metrics

Then, make a graph on Prometheus UI. http://localhost:9090/

1. Fork it ( https://github.com/kazegusuri/fluent-plugin-prometheus/fork )
2. Create your feature branch (git checkout -b my-new-feature)
3. Commit your changes (git commit -am 'Add some feature')
4. Push to the branch (git push origin my-new-feature)
5. Create a new Pull Request