如何在NiFi中更新流文件属性值数据类型(字符串到字节)



我使用的是NiFi 1.8.0.3.3.0.0-165版本,没有转换属性值数据类型(字符串到字节(的想法。

是否可以转换NiFi流文件属性的数据类型。

对于可以使用本指南的属性Apache NiFi Expression语言指南如果你没有找到解决方案,你可以使用groovy脚本来加载你的属性,并执行你想要的

def flowFile = session.get()
if(!flowFile) return

def val = flowFile.getAttribute('yourattribue')
//mod your val 
flowFile = session.putAttribute(flowFile, 'yourattributeout', yourattributeout)
session.transfer(flowFile, REL_SUCCESS)

相关内容

  • 没有找到相关文章