Назад | Перейти на главную страницу

Событие Routing Fluent Bit tcp не соответствует Fluent

Я новичок в Fluent и Fluent Bit.

Fluent Bit (0.13) слушает tcp и пересылает его экземпляру Fluent (td-agent 3.2). Fluent подтолкнет его к rabbitmq. Основной процесс - рабочий.

Fluent Bit генерирует такие сообщения, как

2018-07-09T11: 44: 48 + 02: 00 tcp.0
{"msg": ["dev.fluent", 1531129488, {"test": "woooooooo 2018-07-09 11:44:48"}]}

перенаправляемый тег - tcp.0. К сожалению, Fluent ожидает следующего формата.

2018-07-10T10: 15: 13 + 02: 00 dev.fluent {"birds": "синие 2018-07-10 10:15:13"}

Маршрутизация rabbitmq (tag = routing_key без какой-либо другой конфигурации) будет работать правильно с этим «старым» форматированием.

Я не нашел никакого решения, чтобы переписать тег сообщения парсерами / фильтрами. Есть у кого-нибудь идея сделать роутинг?

Ура Крис