如何根据流文件中的数据过滤流文件？

Question

一个输出流文件有 23 行数据，流文件中的每一行都有一个键和值。队列中有很多相似的流文件，如果其中任何一个流文件没有所需的所有数据行，它们需要进入不匹配的队列。我应该使用哪种处理器或方法来实现此场景，或者我可以在 jolt 中进行此过滤吗？

Answer 1

一种方法是使用像

ExecuteGroovyScript

这样的处理器（https://nifi.apache.org/docs/nifi-docs/components/org.apache.nifi/nifi-groovyx-nar/1.25.0 /org.apache.nifi.processors.groovyx.ExecuteGroovyScript/index.html）。在其中，您可以访问流文件来检查所有行，然后根据检查结果路由到不同的关系（成功/失败）。