加前缀或sufix在nifi tailFile处理器

Question

在我的项目，我使用Nifi阅读从Tomcat日志文件，并在火花的应用处理这些数据，之后，在DB插入的过程数据。

但我的问题是，在应用服务器层面，我有2个不同的盒子4 Tomcat集群（4个不同的日志文件），我有标示出哪些数据是从哪个集群的火花水平。在目前的设置我在Nifi 2 tailFile处理器，其指向单个外港，在每盒但不能够识别哪些数据是从哪个群集在火花水平。

是否有tailFile处理器的任何选项，每个记录添加一些后缀或前缀或文件名（或属性）？这样我就可以确定每个记录是从哪个集群来的，并以这种方式坚持db？

任何帮助将高度赞赏....

在此先感谢

Answer 1

日志文件名保存在TailFile处理器后tailfile.original.path属性

因此，TailFile处理器代替另一处理器之后这会将所需的前缀添加到flowfile内容。例如你可以使用ReplaceText。