fluent-plugin-label-router

Fluentd output plugin to route records based on their Kubernetes metadata.

Installation

RubyGems

$ gem install fluent-plugin-label-router

Specific install

$ gem install specific_install && gem specific_install -l https://github.com/banzaicloud/fluent-plugin-label-router.git

Bundler

Add following line to your Gemfile:

gem "fluent-plugin-label-router"

And then execute:

$ bundle

Configuration

The configuration builds from <route> sections. Each route section can have several <match> statement. These statements computed in order and positive (or in case of negate true negative) results break the evaluation. We can say that the sections are coupled in a lazy evaluation OR.

<match example.tag**>
  @type label_router
  <route>
     ...
  </route>
  <route>
    <match>
      ...
    </match>
    <match> #Exclude
      negate true
      ...
    </match>
  </route>
</match>

Configuration reference

Parameter	Description	Type	Default
emit_mode	Emit mode. If `batch`, the plugin will emit events per labels matched. Enum: record, batch	enum	batch
sticky_tags	Sticky tags will match only one record from an event stream. The same tag will be treated the same way	bool	true
default_route	If defined all non-matching record passes to this label.	string	""
default_tag	If defined all non-matching record rewrited to this tag. (Can be used with label simoultanesly)	string	""
<route>	Route the log if match with parameters defined	[]route	nil

<route>

Parameter	Description	Type	Default
@label	Route the matching record to the given `label`	string	""
tag	Tag the matching record to the given `tag`	string	""
<match>	List of match statements. Repeatable.	[]match	nil

<match>

Parameter	Description	Type	Default
labels	Label definition to match record. Example: `app:nginx`	Hash	nil
namespaces	Comma separated list of namespaces. Ignored if left empty.	[]string	nil
namespace_labels	Label definition of the namespace a record originates. Example: `kubernetes.io/metadata.name=default`	Hash	nil
hosts	Comma separated list of hosts. Ignored if left empty.	[]string	nil
container_names	Comma separated list of container names. Ignored if left empty.	[]string	nil
negate	Negate the selector meaning to exclude matches	bool	false

Rules of thumb

Defining more than one namespace in namespaces inside a match statement will check whether any of that namespaces matches.
Using sticky_tags means that only the first record will be analysed per tag. Keep that in mind if you are ingesting traffic that is not unique on a per tag bases. Fluentd and fluent-bit tail logs from Kubernetes are unique per container.
The plugin does not check if the configuration is valid so be careful to not define statements like identical match statement with negate because the negate rule will never be evaluated.

Examples

1. Route specific `labels` and `namespaces` to `@label` and new `tag`

Configuration to re-tag and re-label all logs from default namespace with label app=nginx and env=dev.

<match example.tag**>
  @type label_router
  <route>
    @label @NGINX
    tag new_tag
    <match>
      labels app:nginx,env:dev
      namespaces default
    </match>
  </route>
</match>

2. Exclude specific `labels` and `namespaces`

Configuration to re-tag and re-label all logs that not from default namespace and not have labels app=nginx and env=dev

<match example.tag**>
  @type label_router
  <route>
    @label @NGINX
    tag new_tag
    <match>
      negate true
      labels app:nginx,env:dev
      namespaces default
    </match>
  </route>
</match>

Example records

Input

@label = ""; tag = "raw.input"; {"log" => "", "kubernetes" => { "namespace_name" => "default", "labels" =>  {"app" => "nginx", "env" => "dev" } } }
@label = ""; tag = "raw.input"; {"log" => "", "kubernetes" => { "namespace_name" => "kube-system", "labels" =>  {"app" => "tiller" } } }

Output

@label = "@NGINX"; tag = "new_tag"; {"log" => "", "kubernetes" => { "namespace_name" => "default", "labels" =>  {"app" => "nginx" } } }
nil

2. Both `labels` and `namespace` are optional

Only labels

<match example.tag**>
  @type label_router
  <route>
    @label @NGINX
    tag new_tag
    <match>
      labels app:nginx
    </match>
  </route>
</match>

Only namespace

<match example.tag**>
  @type label_router
  <route>
    @label @NGINX
    tag new_tag
    <match>
      namespaces default
    </match>
  </route>
</match>

Rewrite all

<match example.tag**>
  @type label_router
  <match>
    @label @NGINX
    tag new_tag
  </match>
</match>

3. One of `@label` ot `tag` configuration should be specified

If you don't rewrite either of them fluent will likely to crash because it will reprocess the same messages again.

4. Default route/tag

Use default_label and/or default_tag to route non matching records.

<match example.tag**>
  @type label_router
  default_route @default_sink
  <route>
     ...
  </route>
</match>

Copyright

License
- Apache License, Version 2.0