我有一个用例，其中我必须使用NiFi定期为特定索引获取新记录(仅以前未获取的记录)，然后将其通过管道传输到其他存储，并进行一些ETL。
我不确定如何处理仅提取新记录。有人处理过这样的用例吗？
最佳答案
您可以更详细地了解仅获取新记录吗？
当您说时，只记录未在之前获取的记录，这是否意味着特定的时间轴？
哪些记录被称为新记录？有特定时间要求吗？
我有一个用例，其中我必须使用NiFi定期为特定索引获取新记录(仅以前未获取的记录)，然后将其通过管道传输到其他存储，并进行一些ETL。
我不确定如何处理仅提取新记录。有人处理过这样的用例吗？
最佳答案
您可以更详细地了解仅获取新记录吗？
当您说时，只记录未在之前获取的记录，这是否意味着特定的时间轴？
哪些记录被称为新记录？有特定时间要求吗？