hadoop - 如何访问水槽事件 header 属性？

我在Flume中添加了一些事件 header 属性，但是我不确定如何在flumeagent配置文件中访问它

例如:我使用添加了fileHeader
flumeagent.sinks.sinkname.hdfs.fileHeader = true
目的是能够在路径中添加事件 header 属性，
例如:flumeagent.sinks.sinkname.hdfs.path = /user/name/flumedir/%y-%m-%d/event-attribute

最佳答案

发现您可以使用以下命令添加文件名或绝对文件路径
flumeagent.sources.src1.fileHeader = trueflumeagent.sources.src1.fileHeaderKey = fileflumeagent.sources.src1.basenameHeader = trueflumeagent.sources.src1.basenameHeaderKey = basename
注意:以上是在源中添加的，但在接收器中使用
flumeagent.sinks.sinkname.hdfs.path = /user/name/flumedir/%y-%m-%d/%{file}要么flumeagent.sinks.sinkname.hdfs.path = /user/name/flumedir/%y-%m-%d/%{basename}

关于hadoop - 如何访问水槽事件 header 属性？，我们在Stack Overflow上找到一个类似的问题：https://stackoverflow.com/questions/27004261/