1

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

从 convertavrotojson 处理器流文件中得到以下属性

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

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

期望以下输出 { "id": "1", "details":[ { "mobileno": "xxxxx", "name": "AAAA", "address": "addressline1" } ], "status" :"真的” }

4

1 回答 1

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

于 2018-02-15T14:00:30.040 回答