Category "fluent"

In fluentd how to parse logs and create fields based on key values

In fluentd how do i parse this log and get fields like ip, method and severity by using grok pattern or json {"log":"2019-08-09 06:54:36,774 INFO 10.2.1.200 [0

Is it possible to work with different schemas in Fluent with PostgreSQL?

I need to create tables with different number of fields for different users. I want to create a schema for each user, and in it a custom set of tables. I can do

FluentD: record_transformer conditional statements

How to put conditional if else statements in fluentd record_transformer and add output to column. eg: <filter nifi.*> @type record_transformer enabl