fluent-plugin-time-sliced-filter
TimeSlicedOutput Plugin to aggregate by unit time
Installation
$ gem install fluent-plugin-time-sliced-filter
Configuration
<match my.**>
type time_sliced_filter
filter_path /foo/bar/my_filrer.rb
time_slice_format %Y%m%d%H%M%S
#prefix filtered
#emit_each_tag false
#pass_hash_row false
#include_tag_key false
#include_time_key false
</match>
<match filtered.my.**>
type stdout
</match>
Usage
# Count the number of records of every unit time
proc {|records|
# `records` is an Array such as:
# [[tag, time, record], [tag, time, record], ...]
#
# e.g.)
# [["my.data", 1391820170, {"hoge"=>"fuga"}],
# ["my.data", 1391820170, {"hoge"=>"fuga"}],
# ["my.data", 1391820170, {"hoge"=>"fuga"}],
# ...
{'count' => records.count}
# or [{...},{...},{...}, ...]
}
Contributing
- Fork it
- Create your feature branch (
git checkout -b my-new-feature
) - Commit your changes (
git commit -am 'Add some feature'
) - Push to the branch (
git push origin my-new-feature
) - Create new Pull Request