在 PutFile (Apache - NiFi) 之后执行 Python 脚本

Question

我正在尝试做一些我认为应该相对简单的事情，但是我在构思如何执行这个过程时非常努力。

在高层次上，我只是将一个 zip 文件解压缩到一个目录中。完成后，我需要执行一个 python 脚本。

我遇到的问题是我无法确定实现此目标的最佳方法。我假设通知/等待将是答案，但是设置释放信号标识符并仅在放置所有流文件时才释放，似乎不可能？我也尝试过使用类似属性的 MergeContent，但我只想要一个合并的流文件，并且我无法将最小条目数 = 设置为 ${fragment.count}。请参阅下面的任何可能有益的屏幕截图。谢谢。

Answer 1

如果您使用UnpackContent，所有解压的流文件都会获得片段标识符、索引和计数属性 - 请参阅文档的写入属性部分。

如果您想将所有这些收集到一个 FlowFile 中，您可以使用 MergeContent 和 Merge Strategy 或 Defragment。这将采用 UnpackContent 创建的所有流文件并将它们合并到一个流文件中 - 它将按 identifier 分组并等到它看到每个 index 到 count - 因此如果产生了 16 个流文件, 它将所有 16 合并为 1。

您可以使用该单个 FlowFile 来触发您的脚本。