处理来自 GetS/List 个 SFTP 处理器的最新文件

Question

我正在从 List SFTP 处理器获取多个文件。但是要求只根据文件的最后修改时间处理最新的文件。我尝试通过合并内容处理器合并文件，但最后修改时间消失了。 Nifi 当前版本为 1.6，因此无法使用记录集编写器。它的解决方案如何实施。

Answer 1

您可以使用 AttributesTo*Processor 并根据 filename 和 file.lastModifiedTime 属性创建新的流文件。然后，您可以合并内容以获得包含文件名和修改时间的单个流文件。您应该能够从这里获取文件。