Как отправить тег при использовании атрибута сервера в Fluentd

Я очень плохо знаком с языком, поэтому это может быть очень простой вопрос. Я хочу отправить данные с одного беглого другого напрямую (используя <server> атрибут) вместо записи в файловую систему, но я не могу найти способ отправить тег с <server> приписывать.

Что я пробовал это:

<match testString>
  type forward
  buffer_chunk_limit 1m
  buffer_queue_limit 6000
  flush_interval 5s
  flush_at_shutdown true
  heartbeat_type tcp
  heartbeat_interval 3s
  num_threads 50
  <server>
    host **.**.**.****
    port ******
    tag testTagName
  </server>
</match>

Но когда я запустил конфиг, он дает мне:

2016-03-11 13:33:41 +0000 [warn]: parameter 'tag' in <server>
  host **.**.**.***
  port *****
  tag testTagName
</server> is not used.

1 ответ

Я не думаю tag будет работать в <server> приписывать. Вместо этого вы можете forward журналы на удаленный fluentd-aggregator в port 24224 и там вы могли бы использовать tag в <source> атрибут fluentd-aggregatorКонфигурационный файл.

fluend-forwarder.conf

<match testString>
type forward
buffer_chunk_limit 1m
buffer_queue_limit 6000
flush_interval 5s
flush_at_shutdown true
heartbeat_type tcp
heartbeat_interval 3s
num_threads 50
<server>
   host **.**.**.****
   port 24224
</server>
</match>

fluentd-aggregator.conf

<source>
  @type forward
  port 24224
  tag testTagName
</source>

<match testTagName>
  ...
</match>
Другие вопросы по тегам