nifi中json组的颠簸变换

Question

我对nifi很陌生。我需要帮助，以制作新的json模板使用震击转换处理器。有谁能帮我为这个要求制定颠簸规格吗？

从convertavrotojson处理器流文件中获取以下属性

姓名、地址、身份、身份

从它的内容文件中，我得到了手机。

期望输出{ "id"："1"，“详细信息"：{ "mobileno"："xxxxx"，"name”："AAAA"，"address"："addressline1“}，"status”:"true“}

Answer 1

由于您有名称，地址，id，状态属性的流文件，在新版本的NiFi-1.2+，我们可以添加属性到json消息使用jolt。

尝试使用以下抖动规范：-

[
  {
    "operation": "shift",
    "spec": {
      "mobileno": "details[0].mobileno"
    }
  },
 {
        "operation": "default",
        "spec": {
          "id":"${id}",
          "status":"${status}",
            "details[]": {
                "*": {
                  "name":"${name}",
                  "address":"${address}"
                }
            }
        }
    }
]

Config截图：-

​

获得更多参考

https://community.hortonworks.com/questions/152046/nifi-how-to-use-jolt-to-add-json-keyvalue-dynamica.html