NiFi Jolt规范中的@timestamp错误

Question

我在震动转换中遇到@timestamp参数错误：

[
{
"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),'')"
}
}
}
}
]

输入ex:

{
"timestamp": 1559350080,
"param": 12
}

在Jolt变换中可以使用字符@吗？

Answer 1

@是一个特殊的字符。需要使用转义符(\(作为前缀，以便通过将"@timestamp"密钥替换为"\@timestamp"使其成为文字。

通过这种方式，您将在输出中使用"@timestamp" : "1559350080000"作为键值对。