我想在 Nifi 中实现以下请求响应场景。我的目标是在更多不同的处理器中使用每个值作为数组(对象键 1,对象键 2,...)。
因此,如果我可以将其转换为多个 JSON,那么使用拆分 JSON,我可以稍后使用多个值。
请为此提出各种解决方案。
输入 JSON:
[
{
"ID": "789654",
"Date": "29th Feb",
"Key" : ["object key 1", "object key 2", "object key 3"....]
}
]
输出 JSON:
[
{
"ID": "789654",
"Date": "29th Feb",
"Key1" : "object key 1"
},
{
"ID": "789654",
"Date": "29th Feb",
"Key2" : "object key 2"
},
{
"ID": "789654",
"Date": "29th Feb",
"Key3" : "object key 3"
},
.
.
.
.
.
.
]
你有两个级别的数组。我假设在根数组中你可以有几个对象
[
{
"ID" : "111",
"Date" : "29th Feb",
"Key" : ["object key 1", "object key 2", "object key 3", "object key 4"]
},
{
"ID" : "222",
"Date" : "27th Feb",
"Key" : ["object key 5", "object key 6"]
}
]
使用以下流程
- SplitJson - 通过根数组分割文件
$
- EvaluateJsonPath - 提取
$.ID
and $.Date
值转换为具有相应名称的属性
- SplitJson - 分割文件
$.Key
- ReplaceText - 上一步的结果是无效的 json,因为您有一个字符串数组
Key
。您必须用双引号将字符串括在内容中:(?s)(^.*$)
-> "$1"
- EvaluateJsonPath - 从上下文中提取字符串
$
into Key
属性
- AttributesToJson - 从属性构建 json 的最后一步
极其另类的变体
Use ExecuteGroovyScript
与脚本:
@Grab(group='acme.groovy', module='acmenifi', version='20190218')
import static groovyx.acme.nifi.AcmeNiFi.*
withFlowFile(this).withJson{json,attr->
json.each{o1->
o1.Key.each{k1->
//build new file with json
newFlowFile(this).withJson{json2,attr2->
attr2.putAll(attr)
return o1 + [Key:k1] //set content of new flow file
}
}
}
return null //drop current file
}
本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系:hwhale#tublm.com(使用前将#替换为@)