Я новичок в 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 без какой-либо другой конфигурации) будет работать правильно с этим «старым» форматированием.
Я не нашел никакого решения, чтобы переписать тег сообщения парсерами / фильтрами. Есть у кого-нибудь идея сделать роутинг?
Ура Крис