Nifi：从分裂的日志流文件中创建一个流文件

Question

我想为nifi处理器创建日志文件，我让它们形成tailFail并逐行分割文本，然后检查它是错误，信息还是警告日志和路由到executioncript处理器但在这个时候我有5个流程文件，我想统一这个拆分流文件并将其写入一个流文件，我试图使用合并内容，但我认为它不适合我的任务。

1. 我也想知道如果 所有处理器nifi自定义日志返回日志文件，我在工作流程增加了，是它nessecary到 里面添加logback.xml追加程序。
2. 我想知道是否可以统一分割日志数据？ （P.S我试图routeonAttriute还，但它不为我工作） 我的工作流程是这样的：

Answer 1

后分割线就可以使用RouteOnContent检查该行正则表达式匹配。

然后，如果你想加入行，你可以使用下面的脚本。

这只是一个例子：

//get 1000 flow file list from incoming queue but not more then 1000 
def ffList = session.get(1000) 
if(!ffList)return 

ffList.each{ff-> 
    session.read(ff, {rawIn -> 
     //you can write here to a new output flowfile 
     //but in this example i will just add content into a plain file on disk 
     new File('./logs/warn.log') << rawIn << '\n' 
    } as InputStreamCallback) 

    session.remove(ff) 
}