У меня есть служба, из которой я пытаюсь записывать журналы и отправлять их в определенные места в зависимости от того, к чему они относятся. Fluentd имеет смысл. В настоящее время у меня просто все выгружается на s3, и это отлично работает. Однако теперь я хочу, чтобы небольшое подмножество (любая строка, начинающаяся с фразы «ACTION:») также было отправлено в базу данных mongo. Я все еще хочу, чтобы все отправлялось на s3.
У меня есть этот файл конфигурации, который, конечно же, не сработает.
<source>
@type forward
@id input
@label mainstream
port 24224
</source>
<label @mainstream>
<match foo.**>
@type copy
<store>
@type s3
...
</store>
<store>
@type rewrite_tag_filter
rewriterule1 log "^ACTION:" foo.bar
</store>
</match>
<match foo.bar>
@type mongo
...
</matc>
</label>
Все это будет собрано и остановлено, как только мы дойдем до первого тега соответствия, нормальное поведение rewrite_tag_filter
, похоже, не проходит мимо <store>
.
Другое, что пробовал.
- Копирование s3
store
, чтобы он использовался дважды. Однако я не хочу, чтобы мои выходы s3 были разделены. - Перенаправить самому себе на другой порт, запустить источник через другую метку, однако он не подключится.
Я уверен, что то, о чем я прошу, не слишком безумно. Кто-нибудь делал что-то подобное раньше?