Apache Nifi - 将行存储到 1 个文件中

Apache Nifi - store lines into 1 file

使用 Apache Nifi,我创建了一个读取 Json 文件并逐行拆分以验证内容是否正确的流程。之后我有 2 个输出:1 - 成功的行和 2 - 不成功的行,输出是一个 Json 文件。

目前,所有行都存储在单独的文件中,但我想做的是将每个 "good" 行存储到 1 个文件中,每个 "bad" 一个存储在另一个文件中。

我应该使用什么处理器?

RouteText 处理器专为您的目的而设计。它允许您根据您创建的表达式将文本行路由到不同的关系。它将每个 FlowFile 中的行针对每个关系捆绑在一起。

您可以在此处查看它的文档:https://nifi.apache.org/docs/nifi-docs/components/org.apache.nifi.processors.standard.RouteText/index.html

您可以在此处使用 RouteText 获取示例模板(几乎完全按照您的意愿行事):https://github.com/hortonworks-gallery/nifi-templates/blob/master/templates/SplitRouteMergeVsRouteText.xml