Apache NiFi自定义属性在RouteOnAttribute中无法生效求助

• 先确认自定义属性是否生成成功
  在UpdateAttribute组件后面添加一个LogAttribute，把所有属性打印出来，重点看你创建的自定义属性是否存在，值是不是你预期的内容。要注意：

  • EvaluateJson的JSON路径有没有写错，比如$.user.type这种路径是否和返回的JSON结构匹配，大小写是否一致；
  • UpdateAttribute里设置的属性名，和后续RouteOnAttribute引用的名称要完全一致（NiFi属性名区分大小写）。

• 检查RouteOnAttribute的条件表达式

  • 确认表达式语法正确，比如判断字符串相等要用${自定义属性:equals('目标字符串')}，数值判断用${自定义属性:isEqualTo(100)}，别写错函数名；
  • 多条件组合时，逻辑运算符（and/or）要正确，括号要配对，比如${attr1:equals('a')} and ${attr2:isEqualTo(2)}；
  • 可以先简化条件，用单个条件测试，看数据是否能正确路由，逐步定位问题。

• 查看组件日志与数据队列

  • 打开RouteOnAttribute的组件日志，看有没有报错，比如“属性不存在”“表达式语法错误”这类提示；
  • 检查上游EvaluateJson和UpdateAttribute的队列，有没有数据处理失败的情况，比如JSON解析错误导致属性没生成，数据直接进入失败队列。

• 验证路由分支配置

  • 检查每个路由分支的名称是否和条件里的配置一致，有没有拼写错误；
  • 确认默认分支的设置，如果所有数据都走到默认分支，说明你的条件和实际属性值不匹配，需要重新核对属性值和条件逻辑。

内容的提问来源于stack exchange，提问作者silentsudo