Plugin Helper: Extract
The
extract plugin helper extracts tag or time from the event record according to the configuration.Here is an example:
require 'fluent/plugin/output'
module Fluent::Plugin
class ExampleOutput > Output
Fluent::Plugin.register_output('Example')
def process(tag, es)
es.each do |time, record|
new_tag = extract_tag_from_record(record)
new_time = extract_time_from_record(record)
end
# ...
end
end
This method extracts
tag from the given record.record: event record
Example:
new_tag = extract_tag_from_record(record)
This method extracts
time from the given record.record: event record
Example:
new_time = extract_time_from_record(record)
If this article is incorrect or outdated, or omits critical information, please let us know. Fluentd is an open-source project under Cloud Native Computing Foundation (CNCF). All components are available under the Apache 2 License.
Last modified 2yr ago