DataFrame 输入的 JOLT 规范 (NiFi JoltTransformJson)

Question

您能帮我为以下内容编写 JOLT 规范吗？

输入 JSON：

{
  "a": "1",
  "b": "2",
  "c": "3",
  "d": "4"
}

我需要得到输出：

{
  "columns": ["a","b","c","d"],
  "data": [[1,2,3,4]]
}

Answer 1

您可以使用下面的 shift 转换：

[
  {
    "operation": "shift",
    "spec": {
      "*": {
        "$": "columns",
        "@": "data[0]"
      }
    }
  }
]

如果数据数组的元素必须是严格的整数类型，那么也需要一个modify-overwrite-beta转换，比如

[
  {
    "operation": "modify-overwrite-beta",
    "spec": {
      "*": "=toInteger"
    }
  },
  {
    "operation": "shift",
    "spec": {
      "*": {
        "$": "columns",
        "@": "data[0]"
      }
    }
  }
]