在Apache NiFi中对JSON Jolt中concat的支持

Question

使用Apache NiFi，我希望在JSON流文件中的所有元素中添加一个新字段，该字段基于两个其他字段的串联。我试图使用JoltTransformJSON处理器来处理这个问题，但是，我想使用的Jolt转换可以使用在线工具，但在NIFI中不起作用。我怀疑是版本问题，但我的Jolt规范可能有一些愚蠢的地方。

输入JSON如下所示...

[
  {
    "id": 485842,
    "cc": 1,
    "x": 0,
    "y": null
  },
  {
    "id": 281733,
    "cc": 1,
    "x": 0,
    "y": 10
  },
  {
    "id": 721412,
    "cc": 12,
    "x": 0,
    "y": null
  }
]

[ {
  "id" : 485842,
  "cc" : 1,
  "x" : 0,
  "y" : null,
  "id_cc" : "485842_1"
}, {
  "id" : 281733,
  "cc" : 1,
  "x" : 0,
  "y" : 10,
  "id_cc" : "281733_1"
}, {
  "id" : 721412,
  "cc" : 12,
  "x" : 0,
  "y" : null,
  "id_cc" : "721412_12"
} ]

[{
  "operation": "modify-default-beta",
  "spec": {
    "*": {
      "id_cc": "=concat(@(1,id),'_',@(1,cc))"
    }
  }
}]

{
    "operation": "modify-default",
    "spec": {
      "*": {
        "id_cc": "=concat(@(1,id),'_',@(1,cc))"
      }
    }
}

"operation": "modify-default"

提前感谢您的指点。

Answer 1

经过同事们的一些帮助，我找到了一个让这个工作的方法。

首先，将JoltTransformJSON处理器的Jolt TransformJSON属性设置为Chain。

其次，将Jolt规范设置为以下...

[{
    "operation": "modify-default-beta",
    "spec": {
      "*": {
        "id_cc": "=concat(@(1,id),'_',@(1,cc))"
      }
    }
}]

得到所有这些正确的，预期的输出将产生。