Nifi 在运行时使用 UpdateAttribute 重置计数器变量

Question

有一个通过 SFTP 将文件发送到远程主机的流程。我希望这些文件根据计数器的值进入主机上的不同目录。

因此 PutSFTP 的 RemotePath 值为“/input_data/${counter}”

在 PutSFTP 之前是 UpdateAttribute 处理，设置计数器的值，每个流文件上的计数器值仅增加 1。

但是，在UpdateAttribute中，是否可以在计数器达到某个值时将其重置为0或1？说当“计数器”达到 5 时，重置为 0

Answer 1

尝试使用模函数：

Name: counter
Value: ${counter:isEmpty():ifElse('0', '${counter:toNumber():mod(5):plus(1)}')}

这样当该值达到 5 时，它将在下一个文件中重置为 0。