Способ извлечь значения в конфигурации Fluentd из строки журнала для использования в качестве выходного параметра?

Question

Я пытаюсь выяснить, могу ли я извлечь значения из записи в конфигурации соответствия и использовать их в качестве значений для конфигурации параметров.В частности, используя выходной плагин amqp (https://github.com/giraffi/fluent-plugin-amqp).. В приведенном ниже примере, я полагаю, я мог бы извлечь поле job_id и использовать его в качестве значения для параметра exchange. Для хоста, я полагаю,что я мог бы взять то же значение и передать его в качестве аргумента некоторому встроенному коду Ruby.

<match sometag>
  @type amqp
  exchange record.job_id
  host "#{lookup_output_host(record.job_id)}"
  ... blah blah blah ...
</match>

Альтернативный способ получить требуемый job_id - это извлечь его из пути к исходному файлу, но яЯ тоже не уверен, как это сделать.

Или мне нужно написать собственный плагин?

Answer 1

Хотите извлечь значение (job_id) из записей?fluent-plugin-amqp не поддерживает извлечение значения конфигурации из записей.fluent-plugin-amqp отправляет записи на хост, который определен в конфигурации статически.