我需要我的NiFi控制器服务定期更新。有办法做到这一点吗?
有关详细信息:我有两个文件1。Customer_Info和2。销售信息
Customer_Info
文件包含cust_id
、name
、address
等信息。
Sales_Info
包含类似于sales_id
、cust_id
、date_id
的信息。
这两份文件每天都会收到。现在,我想在NiFi中合并这两个文件。为此,我使用CSVRecordLookupService查找服务。但一旦加载了文件,我看不到用收到的新文件重新加载它的方法。
每个控制器服务都将实现定期更新自身的逻辑,因为它依赖于控制器服务正在做的任何事情。
不幸的是,CsvRecordLookupService不会定期更新自己,但我认为可以实现一个增强功能来实现这一点。PropertiesFileLookupService就是一个更新自身的例子。