Class: Fluent::RecordSerializerFilter

Inherits:
Filter
  • Object
show all
Includes:
RecordSerializer, SetTagKeyMixin
Defined in:
lib/fluent/plugin/filter_record_serializer.rb

Instance Method Summary collapse

Methods included from RecordSerializer

#serialize_record

Instance Method Details

#filter(tag, time, record) ⇒ Object 



13
14
15
16
17
18
19
20
21
22
 
# File 'lib/fluent/plugin/filter_record_serializer.rb', line 13

def filter(tag, time, record)
  begin
    serialized_record = serialize_record(@format, record)
  rescue => e
    $log.warn "serialize error: #{e.message}"
    return
  end

  {'tag' => tag, @field_name => serialized_record}
end