根据NiFi中的内容更新属性
在开发Apache NiFi cusom处理器时,如何向当前流文件添加属性.
我想要做的是将新属性(或至少更新当前属性)添加到具有计算值的当前流文件.
或者我可以使用已经构建的处理器吗？
NiFi支持多种创建和更新属性的方法,具体取决于您希望使用的数据源.一些通用处理器包括:
UpdateAttribute - 使用静态值和NiFi的表达式语言更新流文件的属性.
您可以使用一个处理器添加任意数量的属性.我建议您浏览Apache NiFi表达语言指南,以了解您可以使用它做什么.
ExtractText - 通过将正则表达式应用于流文件内容来设置属性值.
ExecuteScript - ExecuteScript运行自定义脚本代码,可用于根据需要更新属性.
特定内容格式还有更多内容,例如:
- EvaluateJsonPath - 用于JSON
- EvaluateXPath - 用于XML