在 NiFi 中,我正在处理包含以下属性的流文件:
Key: 'my_array'
Value: '[u'firstElement', u'secondElement']'
我想在此数组上拆分 flowFile 以单独处理每个元素(然后合并)。我尝试使用SplitJson
处理器,但它需要 JSON 内容来操作,所以我使用AttributesToJSON
在它之前。不幸的是,生成的 flowFile 的内容是:
{"my_array": "[u'firstElement', u'secondElement'"}
我收到错误
$['my_array'] 的计算值 [u'firstElement', u'secondElement'] 不是 JSON 数组兼容类型,无法拆分。
是否可以转换my_array
字符串到正确的 JSON 数组?我需要使用吗ExecuteScript
或者有一些更简单的方法吗?
怎么样ReplaceText
with Replacement Strategy
of Always Replace
and Replacement Value
of ${my_array}
进而SplitJSON
?
这将用该属性的值替换您的 FlowFile 的内容,然后您可以SplitJSON
on it.
本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系:hwhale#tublm.com(使用前将#替换为@)