Nifi:making 来自拆分日志流文件的一个流文件

Question

我想为 nifi 处理器制作日志文件，我从 tailFail 获取它们并逐行拆分文本然后检查它是否是错误、信息或警告日志并路由到 executescript 处理器但此时我有 5 个流文件我想统一这个拆分流文件并将其写入一个流文件，我尝试使用合并内容，但我认为它不适合我的任务。

1. 我也想知道nifi自定义日志是否为return日志文件 我在我的工作流程中添加的所有处理器，是否需要 在 logback.xml.
内添加 appender
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)
}