fluent

Milestone: 1

This codec handles fluentd’s msgpack schema.

For example, you can receive logs from fluent-logger-ruby with:

input {
  tcp {
    codec => fluent
    port => 4000
  }
}

And from your ruby code in your own application:

logger = Fluent::Logger::FluentLogger.new(nil, :host => "example.log", :port => 4000)
logger.post("some_tag", { "your" => "data", "here" => "yay!" })

Notes:

  • the fluent uses a second-precision time for events, so you will never see subsecond precision on events processed by this codec.

Synopsis

This is what it might look like in your config file:
# with an input plugin:
# you can also use this codec with an output.
input { 
  file {
    codec => fluent {
    }
  }
}

Details


This is documentation from lib/logstash/codecs/fluent.rb