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 更侧重于存在某种参考数据集的查找连接,输入数据中的某些内容用于执行对参考数据集的查找,然后丰富输入数据。
我有两个来自 NiFi 的流文件,如下所示:
Type:A
id:1
Type:B
id:1
我有一些书面规则告诉我如果 ID 匹配,A 类链接到 B 类。所以在上面的例子中,它是匹配的!
我是否可以使用 NiFi 来比较流文件并找出这种联系?如果没有,最好的方法是什么?我应该研究什么 tools/technologies 才能做到这一点?
提前致谢!
您描述的场景听起来像是流连接,可以使用 Storm、Flink、Spark 等流处理系统来完成
NiFi 更侧重于存在某种参考数据集的查找连接,输入数据中的某些内容用于执行对参考数据集的查找,然后丰富输入数据。