有没有办法安排Nifi控制器服务定期更新



我需要我的NiFi控制器服务定期更新。有办法做到这一点吗?

有关详细信息:我有两个文件1。Customer_Info2。销售信息

Customer_Info文件包含cust_idnameaddress等信息。

Sales_Info包含类似于sales_idcust_iddate_id的信息。

这两份文件每天都会收到。现在,我想在NiFi中合并这两个文件。为此,我使用CSVRecordLookupService查找服务。但一旦加载了文件,我看不到用收到的新文件重新加载它的方法。

每个控制器服务都将实现定期更新自身的逻辑,因为它依赖于控制器服务正在做的任何事情。

不幸的是,CsvRecordLookupService不会定期更新自己,但我认为可以实现一个增强功能来实现这一点。PropertiesFileLookupService就是一个更新自身的例子。

最新更新