json 使用 jolt 变换在 nifi 中形成json

Question

我是nifi新手。我需要帮助来制作新的 json 模板颠簸变换处理器。任何人都可以帮助为这个要求制作 joltspec。

来自 convertavrotojson 处理器流文件我得到以下属性

姓名、地址、身份证、身份

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

期待以下输出 { "id": "1", "details":[ { "mobileno": "xxxxx", "name ": "AAAA", "address": "addressline1" } ], "status" :"true" }

Answer 1

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

尝试使用以下震动规格：-

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

Jolt 配置屏幕截图：-

更多参考

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

json 使用 jolt 变换在 nifi 中形成json

json formation in nifi using jolt transformjson

jolt

apache-nifi