eks_fluent_bit_filters.tf

eks_fluent_bit_filters.tf

      %{if length(var.log_s3_outputs) > 0}
      %{for out in var.log_s3_outputs}
      [FILTER]
          Name                rewrite_tag
          Match               ${var.opensearch_filter}.var.log.containers.*_${out.namespace}_*${out.app}*
          Rule                $kubernetes['container_name'] ^${out.app}$ ${out.tag_prefix}.$TAG ${out.shipping_logs_to_os}
      [FILTER]
          Name                nest
          Match               ${out.tag_prefix}.*
          Operation           lift
          Nested_under        kubernetes
          Add_prefix          kubernetes.
      [FILTER]
          Name                record_modifier
          Match               ${out.tag_prefix}.*
          %{for label in var.opensearch_remove_keys}
          Remove_key          ${label}
          %{endfor}
      %{endfor}
      %{endif}
      [FILTER]
          Name                nest
          Match               ${var.opensearch_filter}.*
          Operation           lift
          Nested_under        kubernetes
          Add_prefix          kubernetes.
      [FILTER]
          Name                record_modifier
          Match               ${var.opensearch_filter}.*
          %{for label in var.opensearch_remove_keys}
          Remove_key          ${label}
          %{endfor}
      %{endif}