Как получить доступ к атрибутам заголовка события flume?

Question

Я добавил несколько заголовков атрибутов событий в Flume, но я не знаю, как получить к нему доступ в flumeagent конфигурационного файла

Ex: Я добавил FileHeader используя

flumeagent.sinks.sinkname.hdfs.fileHeader = true

Цель состоит в том, чтобы быть возможность добавлять атрибуты заголовка события в пути, Ex: flumeagent.sinks.sinkname.hdfs.path = /user/name/flumedir/%y-%m-%d/event-attribute

Answer 1

Обнаруженные вы можете добавить имя файла или абсолютный путь к файлу с помощью следующей

flumeagent.sources.src1.fileHeader = true flumeagent.sources.src1.fileHeaderKey = file

flumeagent.sources.src1.basenameHeader = true flumeagent.sources.src1.basenameHeaderKey = basename

Примечание: выше добавляются в источниках, но она используется в раковинах

flumeagent.sinks.sinkname.hdfs.path = /user/name/flumedir/%y-%m-%d/%{file} или flumeagent.sinks.sinkname.hdfs.path = /user/name/flumedir/%y-%m-%d/%{basename}