fluent-plugin-filter-object-flatten's Introduction

fluent-plugin-filter-object-flatten

Filter Plugin to convert the hash record to records of key-value pairs.

Installation

Add this line to your application's Gemfile:

gem 'fluent-plugin-filter-object-flatten'

And then execute:

$ bundle

Or install it yourself as:

$ gem install fluent-plugin-filter-object-flatten

Configuration

<filter>
  type object_flatten
  #separator .
  #tr [" /", "__"]
</filter>

Usage

$ cat fluent.conf
<source>
  @type forward
  @id forward_input
</source>

<filter>
  type object_flatten
</filter>

<match **>
  @type stdout
  @id stdout_output
</match>

$ fluentd -c fluent.conf

$ echo '{"foo":"bar", "bar":"zoo"}' | fluent-cat test.object
#=> 2015-01-01 23:34:45 +0900 test.object: {"foo":"bar"}
#=> 2015-01-01 23:34:45 +0900 test.object: {"bar":"zoo"}

$ echo '{"foo":["bar", "zoo"]}' | fluent-cat test.object
#=> 2015-01-01 23:34:45 +0900 test.object: {"foo":"bar"}
#=> 2015-01-01 23:34:45 +0900 test.object: {"foo":"zoo"}

$ echo '{"foo":{"bar1":"zoo", "bar2":"baz"}}' | fluent-cat test.object
#=> 2015-01-01 23:34:45 +0900 test.object: {"foo.bar1":"zoo"}
#=> 2015-01-01 23:34:45 +0900 test.object: {"foo.bar2":"baz"}

$ echo '{"foo1":{"bar1":"zoo", "bar2":"baz"}, "foo2":{"bar":["zoo", "baz"], "zoo":"baz"}}' | fluent-cat test.object
#=> 2015-01-01 23:34:45 +0900 test.object: {"foo1.bar1":"zoo"}
#=> 2015-01-01 23:34:45 +0900 test.object: {"foo1.bar2":"baz"}
#=> 2015-01-01 23:34:45 +0900 test.object: {"foo2.bar":"zoo"}
#=> 2015-01-01 23:34:45 +0900 test.object: {"foo2.bar":"baz"}
#=> 2015-01-01 23:34:45 +0900 test.object: {"foo2.zoo":"baz"}

Recommend Projects