我是 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":"are blue 2018-07-10 10:15:13"}
rabbitmq 路由(tag = routing_key,无任何其他配置)可以以这种“旧”格式正常工作。
我没有找到任何使用解析器/过滤器重写消息标签的解决方案。有人知道如何完成路由吗?
干杯克里斯