Sub-second resolution is supported after fluentd v0.14. However, the to_msgpack will only keep the unix second.
|
[tag, time, record].to_msgpack |
A workaround is to us to_msgpack_ext to serialize the time.
[tag, time.to_msgpack_ext, record].to_msgpack
And de-serialize it in the emit.
def write(chunk)
if use_source_timestamp
chunk.msgpack_each {|(tag, time, record)|
# Ruby (version >= 1.9) hash preserves insertion order. So the following item is
# the last item when iterating the 'record' hash.
record[emit_timestamp_name] = Time.at(Fluent::EventTime.from_msgpack_ext(time).to_r)
handle_record(tag, record)
}
else
chunk.msgpack_each {|(tag, record)|
record[emit_timestamp_name] = Time.now
handle_record(tag, record)
}
end
@log.flush
end
Sub-second resolution is supported after fluentd v0.14. However, the to_msgpack will only keep the unix second.
fluentd-plugin-mdsd/src/fluent-plugin-mdsd/lib/fluent/plugin/out_mdsd.rb
Line 72 in 9bacb00
A workaround is to us to_msgpack_ext to serialize the time.
And de-serialize it in the emit.