我是新来的nifi。我需要帮助来使用joltTransfer处理器制作新的json模板。有人可以帮助为这个需求制作joltspec吗？
从转换avrotojson处理器流文件获得以下属性
姓名、地址、身份证、身份
从它的内容文件中，我得到了Mobieno。
需要以下输出{"id"："1"，"详细信息":[ { "Mobieno"："xxxxx"，"name"："AAAA"，"Address"："addressline1" } ], "status"："true"}
由于您有流文件的名称、地址、id、状态属性，在新版本的NiFi-1.2中，我们可以使用jolt将属性添加到json消息中。
尝试以下颠簸规格：-
[
{
"operation": "shift",
"spec": {
"mobileno": "details[0].mobileno"
}
},
{
"operation": "default",
"spec": {
"id":"${id}",
"status":"${status}",
"details[]": {
"*": {
"name":"${name}",
"address":"${address}"
}
}
}
}
]
更多参考资料
https://community.hortonworks.com/questions/152046/nifi-how-to-use-jolt-to-add-json-keyvalue-dynamica.html
