NIFI——如何访问从updateattributes到groovy脚本的自定义变量

Question

Updatedate处理器中有一个自定义变量(state=success(，现在我想访问invokescriptor处理器中groovy脚本中的这些变量。

def status= flowFile.getAttribute('status')

我试过下面提到的两种语法以及

尝试1:

if( status.equals("success")){
//

尝试2:

if(status == "success"){
}

以上两次尝试flowFile.getAttribute('status')返回null值。

请纠正我的错误！

Answer 1

如果您的流文件中有此属性：
key:state
value:success

然后你可以这样得到这个属性：

def status= flowFile.getAttribute("state")

如果你有一个null值，也许你的attribut根本不存在？按照以下流程进行验证：

1-暂停groovyscript处理器
2-创建流文件
3-检查队列中的流文件属性的状态属性