NiFi根据一些规则匹配流文件

NiFi matching flowfiles based on some rules

我有两个来自 NiFi 的流文件,如下所示:

Type:A
id:1

Type:B
id:1

我有一些书面规则告诉我如果 ID 匹配,A 类链接到 B 类。所以在上面的例子中,它是匹配的!

我是否可以使用 NiFi 来比较流文件并找出这种联系?如果没有,最好的方法是什么?我应该研究什么 tools/technologies 才能做到这一点?

提前致谢!

您描述的场景听起来像是流连接,可以使用 Storm、Flink、Spark 等流处理系统来完成

NiFi 更侧重于存在某种参考数据集的查找连接,输入数据中的某些内容用于执行对参考数据集的查找,然后丰富输入数据。