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

For more details, see Extract section.

Methods

extract_tag_from_record(record)

This method extracts tag from the given record.

  • record: event record

Example:

new_tag = extract_tag_from_record(record)

extract_time_from_record(record)

This method extracts time from the given record.

  • record: event record

Example:

new_time = extract_time_from_record(record)

Plugins using extract

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.