Логи доставки из Kubernetes в агрегатор Fluentd.
Есть ли способ преобразовать одно из значений ключа в значение тега? Например, есть значение ключа для application_name. Если бы это можно было преобразовать в значение тега, можно было бы направить на разные выходы.
Спасибо,
После создания записи изменить тег невозможно.
Это можно сделать повторно с помощью фильтра тегов перезаписи
Вы можете сделать что-то вроде этого:
<match kubernetes_logs>
@type rewrite_tag_filter
<rule>
key application_name
pattern (.+)
tag $1
</rule>
</match>
Тем не менее, этот метод позволяет Fluent обрабатывать в два раза больше записей. Если вам нужно только направить записи в разные конечные точки, обычно плагины вывода позволяют фильтровать записи по ключу.
Существует плавный плагин record_transformer. https://docs.fluentd.org/v1.0/articles/filter_record_transformer
<filter foo.bar>
@type record_transformer
<record>
hostname "#{Socket.gethostname}"
tag ${tag}
</record>
</filter>
Пример ввода: {"message":"hello world!"}
Пример вывода: {"message":"hello world!", "hostname":"db001.internal.example.com", "tag":"foo.bar"}
