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

Question

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

def status= flowFile.getAttribute('status')

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

尝试 1：

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

尝试 2：

  if(status == "success"){

  }

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

请指正错误！

Answer 1

如果您的流文件中有此属性：
键：状态
值：成功

那么你可以这样得到这个属性：

def status= flowFile.getAttribute("state")

如果你有一个空值，也许你的属性根本不存在？按照流程进行验证：

1- 暂停您的 groovyscript 处理器
2-制作一个流文件
3- 检查队列中状态属性的流文件属性

NIFI -- How to access the custom variable from updateattributes to groovy script