我如何应用JoltTransformation上的洞json流文件而不分裂它?

Question

下一个流文件是InvoqueHTTP

反应:

[
{
"name": "Rolf",
"sur_name": "ramsfl"
},
{
"name": "Jose",
"sur_name": "maxim"
},
{
"name": "Andrei",
"sur_name": "alexo"
}
]

我想用JoltTransformation代替(ReplaceText)查找"_"并通过emptystring)ReplaceText不是需要的解决方案。

我创建了这个JoltTransformation:

[
{
"operation": "shift",
"spec": {
"name":"name",
"sur_name":"surname"
}
}
]

这个jolttransformation很好地解决了这个问题，但是如果流文件被分割，如果我传递它，它会给出null。

Answer 1

使用JoltTransformRecord处理器:

• Record Reader:JsonTreeReader
Record Writer:JsonRecordSetWriter
• Jolt Transformation DSL:Chain
• Jolt Specification:

[
{
"operation": "shift",
"spec": {
"*": {
"*_*": "[&1].&(0,1)&(0,2)",
"*": "[&1].&"
}
}
}
]

Json输出

[
{
"name": "Rolf",
"surname": "ramsfl"
},
{
"name": "Jose",
"surname": "maxim"
},
{
"name": "Andrei",
"surname": "alexo"
}
]

Answer 2

此规范是否解决了您的问题:

[
{
"operation": "shift",
"spec": {
"*": {
"name": "[&1].name",
"sur_name": "[&1].surname"
}
}
}
]