module Fluent
class SplitMsgFilter < Filter
Fluent::Plugin.register_output('split_msg', self)
# config_param works like other plugins
def configure(conf)
super
end
def filter(tag, time, record)
msgs = record['message'].split("\t")
event_time = msgs[0]
ip = msgs[2]
# replace profile4 or add ip to record or etc...
record
end
end
end
How can we install and use this filter locally in macOS and use it with fluentd config.
--
You received this message because you are subscribed to the Google Groups "Fluentd Google Group" group.
To unsubscribe from this group and stop receiving emails from it, send an email to fluentd+unsubscribe@googlegroups.com.
For more options, visit https://groups.google.com/d/optout.