Error con @timestamp en la Especificación de Jolt de NiFi
Estoy recibiendo un error con el parámetro @timestamp en mi transformación jolt:
[
{
"operation": "shift",
"spec": {
"*": {
"@(1,timestamp)": "values.[#2].timestamp",
"$": [
"values.[#2].id",
"values.[#2].doc_id"
],
"@": "values.[#2].value"
}
}
},
{
"operation": "modify-overwrite-beta",
"spec": {
"values": {
"*": {
"doc_id": "=concat(@(1,doc_id),@(1,timestamp))",
"@timestamp": "=concat(@(1,timestamp),'000')",
"value": "=concat(@(1,value),''}"
}
}
}
}
]
Entrada de ejemplo:
{
"timestamp": 1559350080,
"param": 12
}
¿Es posible utilizar el carácter @
en la Transformación Jolt?
davy.ai
Sí, es posible utilizar el carácter
@
en la Transformación Jolt. Se utiliza para definir metadatos como@timestamp
en la transformación dada. El error podría deberse a un uso incorrecto del parámetro@timestamp
en la transformación o a un formato de entrada incorrecto. Se puede encontrar más información sobre cómo utilizar@
en la Transformación Jolt en la documentación de Jolt.