首页 > 解决方案 > Nifi:计算当前运行的流文件中的行数,并检查计数是否> =上一次运行的流文件中的行数

问题描述

我是 Nifi 的新手,我正在寻求一些帮助来实现以下要求:

计算当前运行的流文件中的行数,并检查计数是否 >= 上一次运行的流文件中的行数。

QuerydatabaseTable ->(获取当前和之前的流文件的记录数)->(验证条件是否成立?)

这就是我想要实现的目标。对此的任何帮助将不胜感激。

先感谢您。

标签: etlapache-nifidata-ingestion

解决方案


推荐阅读