Nifi UpdateAttribute 不适用于动态变量

Nifi UpdateAttribute not working for dynamic variable

我正在尝试获取 ListHDFS 处理的文件数,因此流程如下所示:

ListHDFS -> UpdateAttribute -> LogAttribute

我根据文档(见附件)配置了 UpdateAttribute。奇怪的是,我什至没有在“查看数据来源”选项中看到“fileCount”。

我错过了什么?

我能够在数据来源中看到 fileCount 属性值为 1,

我已将您的场景重新创建为

Generateflowfile --> UpdateAttribute --> LogAttribute

UpdateAttribute 配置:

文件数 ${getStateValue("fileCount"):plus(1)}

状态变量初始值 0

文件出处:

fileCount 属性的初始值为 null(无值) 并且在 UpdateAttribute 中我们正在向 fileCount 属性添加一个,新值为 1