Flume事件修改

作者: 敢嫁就敢娶
发布时间: 2024-04-18 10:26:32 (9天前)
转自：

4 条回复

0#
回复此人
Just do it | 2019-08-31 10-32

<div class =“post-text”itemprop =“text”> <P> 我通过使用Morphline解决了这个问题，在下面添加了这些函数，其中时间戳被添加到每个水槽事件的开头。 <code> { addCurrentTime { field : timestamp } }, <br/> { setValues { _result = "@{timestamp}|@{message}" } }, </code> </p> </DIV>

编辑
1#
回复此人
老人与海 | 2019-08-31 10-32

<div class =“post-text”itemprop =“text”> <P> 假设您的意思是在事件正文字节的开头添加一个时间戳，那么就没有预先设定的拦截器来执行您所要求的操作（搜索和替换拦截器不能替换为动态值，例如日期）。 </p> <P> 但是，编写一个拦截器为每个事件主体添加当前时间戳前缀应该是微不足道的。 </p> <P> 检查现有拦截器的源代码作为示例，编译代码并将jar部署到名为的新文件夹中 <code> $FLUME_HOME/plugins.d/my-plugins/lib/my-plugin.jar </code> </p> <P> 这是标准水槽拦截器的当前来源的链接： </p> <UL> <LI> <a href="https://github.com/apache/flume/tree/trunk/flume-ng-core/src/main/java/org/apache/flume/interceptor" rel="nofollow"> https://github.com/apache/flume/tree/trunk/flume-ng-core/src/main/java/org/apache/flume/interceptor </A> </LI> </UL> <P> 但基本上你只需要创建一个实现的类 <code> Interceptor </code> 界面，并创建一个 <code> Interceptor.Builder </code> 实施也。 </p> </DIV>

编辑
2#
回复此人
咿呀哟 | 2019-08-31 10-32

<div class =“post-text”itemprop =“text”> <P> 您可以使用Flume拦截器： <a href="https://flume.apache.org/FlumeUserGuide.html#flume-interceptors" rel="nofollow"> https://flume.apache.org/FlumeUserGuide.html#flume-interceptors </A> 修改事件。 </p> <P> 您可以编写自己的类来实现您正在寻找的功能，也可以使用Morphline拦截器。 </p> <P> 如果不要求更改正文，则可以使用timestamp拦截器将时间戳添加到标题中。 </p> </DIV>

编辑

登录后才能参与评论