如何使用event header中的key值
发布网友
发布时间:2022-05-01 13:55
我来回答
共1个回答
热心网友
时间:2023-10-16 12:39
在header中添加了一个key为:flume.client.log4j.logger.source ,然后有两个应用程序,一个设置为app1,一个设置为app2。
现在有这么一个需求,要将app1的日志输出到hdfs://master68:8020/flume/events/app1目录下面,app2的日志输出到hdfs://master68:8020/flume/events/app2目录下面,未来也可能有更多的应用程序的日志输出,也即每个程序的日志输出到各自自己的目录下面。
有了前面的头信息之后,我们可以非常简单的实现这个需求:
tier1.sinks.sink1.hdfs.path=hdfs://master68:8020/flume/events/%{flume.client.log4j.logger.source}
只需要改一下这一行,用%{flume.client.log4j.logger.source},来替换具体的app日志目录即可。
热心网友
时间:2023-10-16 12:39
在header中添加了一个key为:flume.client.log4j.logger.source ,然后有两个应用程序,一个设置为app1,一个设置为app2。
现在有这么一个需求,要将app1的日志输出到hdfs://master68:8020/flume/events/app1目录下面,app2的日志输出到hdfs://master68:8020/flume/events/app2目录下面,未来也可能有更多的应用程序的日志输出,也即每个程序的日志输出到各自自己的目录下面。
有了前面的头信息之后,我们可以非常简单的实现这个需求:
tier1.sinks.sink1.hdfs.path=hdfs://master68:8020/flume/events/%{flume.client.log4j.logger.source}
只需要改一下这一行,用%{flume.client.log4j.logger.source},来替换具体的app日志目录即可。