Record Transformer 🔗︎

Overview 🔗︎

Mutates/transforms incoming event streams.

Configuration 🔗︎

RecordTransformer 🔗︎

Variable Name Type Required Default Description
remove_keys string No - A comma-delimited list of keys to delete
keep_keys string No - A comma-delimited list of keys to keep.
renew_record bool No false Create new Hash to transform incoming data
renew_time_key string No - Specify field name of the record to overwrite the time of events. Its value must be unix time.
enable_ruby bool No false When set to true, the full Ruby syntax is enabled in the ${…} expression.
auto_typecast bool No true Use original value type.
records []Record No - Add records docs at: https://docs.fluentd.org/filter/record_transformer
Records are represented as maps: key: value

Example Record Transformer filter configurations 🔗︎ 

apiVersion: logging.banzaicloud.io/v1beta1
kind: Flow
metadata:
 name: demo-flow
spec:
 filters:
   - record_transformer:
       records:
       - foo: "bar"
 selectors: {}
 localOutputRefs:
   - demo-output

Fluentd Config Result 🔗︎ 

<filter **>
 @type record_transformer
 @id test_record_transformer
 <record>
   foo bar
 </record>
</filter>
Edit this page on GitHub