我在GenerateFlowfile处理器中有文本属性,如下所示:
[{
"status": {
"runStatus": "STOPPED"
},
"component": {
"state": "STOPPED",
"id": "ea5db028-015d-1000-5ad5-80fd006dda92"
},
"revision": {
"version": 46,
"clientId": "ef592126-015d-1000-bf4f-93c7cf7eedc0"
}
} ]
以及我的 ExecuteScript 处理器中的相关 groovy 脚本:
import org.apache.commons.io.IOUtils
import java.nio.charset.*
def flowFile = session.get();
if (flowFile == null) {
return;
}
def slurper = new groovy.json.JsonSlurper()
def attrs = [:] as Map<String,String>
session.read(flowFile,
{ inputStream ->
def text = IOUtils.toString(inputStream, StandardCharsets.UTF_8)
text=flowFile.getAttribute('text')
def obj = slurper.parseText(text)
obj.each {k,v ->
attrs[k] = v.toString()
}
} as InputStreamCallback)
flowFile = session.putAllAttributes(flowFile, attrs)
session.transfer(flowFile, REL_SUCCESS)
最佳答案
你的json的根元素是数组的问题
并且您尝试像 map 一样迭代它 .each{k,v-> ... }
可能您想采用第一个映射来迭代它,如下面的代码所示
def obj=[ [a:1] ]
//this line will throw exception:
//obj.each{k,v-> println "$k->$v" }
//but this one not
obj[0].each{k,v-> println "$k->$v" }
仅供引用:有一个EvaluateJsonPath可以从 json 流文件内容中提取属性并将结果放入属性的处理器
关于json - NIFI :Json Content Parsing in FlowFile,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/45736771/