Fluent event to statsd plugin.

Installation

$ fluent-gem install fluent-plugin-statsd

Usage

<match statsd>
  type statsd
  host localhost # optional
  port 8125# optional
</match>

fluent_logger.post('statsd',
  :statsd_type => 'timing',
  :statsd_key => 'org.foo.timing',
  :statsd_timing => 0.234
)

fluent_logger.post('statsd',
  :statsd_type => 'gauge',
  :statsd_gauge => 10,
  :statsd_key => 'org.foo.gauge'
)

fluent_logger.post('statsd',
  :statsd_type => 'count',
  :statsd_gauge => 10,
  :statsd_key => 'org.foo.gauge'
)

fluent_logger.post('statsd',
  :statsd_type => 'set',
  :statsd_gauge => 10,
  :statsd_key => 'org.foo.gauge'
)

fluent_logger.post('statsd',
  :statsd_type => 'increment',
  :statsd_key => 'org.foo.counter'
)


fluent_logger.post('statsd',
  :statsd_type => 'decrement',
  :statsd_key => 'org.foo.counter'
)

td-agent.conf demo

worked with record_reformer to transform access log request_time into statsd

<match accesslog.reformer>
  type copy
  <store>
    type statsd
    host 127.0.0.1
    port 8125
    flush_interval 1s 
  </store>
  # other stores...
</match>
<match accesslog>
  type record_reformer
  output_tag ${tag}.reformer
  # transform /url1/url2/url3 --> url.urlNN.urlNN
  statsd_key ${"url"+request_uri.gsub(/((\/[^\/]+){2}).*/, '\1').gsub(/([^\?]*)\?.*/,'\1').gsub(/[0-9]+/, "NN").gsub(/\//, ".");}
  statsd_timing ${request_time}
  statsd_type ${"timing"}
</match>

Copyright

Copyright (c) 2014- Chris Song

License

Apache License, Version 2.0