Jolt 转换为具有父属性的数组

Question

我正在使用 NiFi Jolt 处理器来转换一些 JSON 数据。

我的 JSON 字段流派包含共享属性和一个包含实际流派名称列表的数组。

我需要将“流派”属性转换为“流派”数组，其中包含常见属性列表和不同流派名称。

我有以下输入 JSON：

{
  "programIdentifier": "9184663",
  "programInstance": {
    "genre": {
      "source": "GN",
      "locked": false,
      "lastModifiedDate": 1527505462094,
      "lastModifiedBy": "Some Service",
      "genres": [
        "Miniseries",
        "Drama"
      ]
    }
  }
}

我尝试了以下规格：

[{
  "operation": "shift",
   "spec": {
     "programIdentifier": ".&",,
     "genre": {
        "source": "genres[].source.value",
        "locked": "genres[].locked",
        "lastModifiedDate": "genres[].lastModifiedDate",
        "lastModifiedBy": "genres[].lastModifiedBy",
        "genres": {
            "*": "genres[&0].name"                
        }
     }
}]

这是我的预期输出：

{
  "programIdentifier": "9184663",
  "programInstance": {
    "genres": [
      {
        "source": {
          value: "GN"
        }
        "locked": false,
        "lastModifiedDate": 1527505462094,
        "lastModifiedBy": "Some Service",
        "name": "Miniseries"
      },
      {
        "source": {
          value: "GN"
        }
        "locked": false,
        "lastModifiedDate": 1527505462094,
        "lastModifiedBy": "Some Service",
        "name": "Drama"
      }
    ]
  }
}

但它的结果是：

{
  "programIdentifier": "9184663",
  "programInstance": {
    "genres": [
      {
    "source": {
      "value": "GN"
    },
    "name": "Miniseries"
       }, {
    "locked": false,
    "name": "Drama"
       }, {
    "lastModifiedDate": 1527505462094
       }, {
    "lastModifiedBy": "Some Service"
       }],
  }
}

Answer 1

这是你想要达到的目标吗？

[
  {
    "operation": "shift",
    "spec": {
      "programIdentifier": ".&",
      "programInstance": {
        "genre": {
          "genres": {
            "*": {
              "@2": {
                "source": "programInstance.genres[&2].source[]",
                "locked": "programInstance.genres[&2].locked",
                "lastModifiedDate": "programInstance.genres[&2].lastModifiedDate",
                "lastModifiedBy": "programInstance.genres[&2].lastModifiedBy"
              },
              "@": "programInstance.genres[&1].name"
            }
          }
        }
      }
    }
  }
]