fluent-plugin-time_parser

Component

TimeParserOutput

Based on the great extract-query-params plugin by @Kentaro. Will take a time attribute and will extract the date and the hour for a given time zone.

wat?!

<match test.**>
  type time_parser

  key            time
  add_tag_prefix extracted.
  time_zone      Asia/Tokyo
</match>

And you feed such a value into fluentd:

"test" => {
  "time" => "2013-05-14T15:14:36Z"
}

Then you'll get re-emmited tags/records like so:

"extracted.test" => {
  "time" => "2013-05-14T15:14:36Z",
  "parsed_time" => "2013-05-15T00:14:36+09:00",
  "parsed_date" => "2013-05-15",
  "parsed_hour" => "0"
}

Configuration

key

key is used to point a key whose value contains the time you want to parse.

remove_tag_prefix, remove_tag_suffix, add_tag_prefix, add_tag_suffix

These params are included from Fluent::HandleTagNameMixin. See the code for details.

You must add at least one of these params.

time_zone

Optional. time_parser uses the TZInfo (http://tzinfo.rubyforge.org/) library to handle time zones.

parsed_time_tag, parsed_hour_tag, parsed_date_tag

The parsed_* parameter names can be configured as well.

Installation

Add this line to your application's Gemfile:

gem 'fluent-plugin-time_parser'

And then execute:

$ bundle

Or install it yourself as:

$ gem install fluent-plugin-time_parser

Contributing

Fork it
Create your feature branch (git checkout -b my-new-feature)
Commit your changes (git commit -am 'Added some feature')
Push to the branch (git push origin my-new-feature)
Create new Pull Request

Copyright

License

Apache License, Version 2.0