加前綴或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。