使用 apache nifi 执行 json 密钥转换

Question

我需要在apache nifi中进行json转换。有效负载中的json键将动态生成。例如，在下面给出的输入中，“客户”具有属性“fname”和“lname”。我需要更改这个“fname”-

因为我是nifi的新手。我不知道从哪里开始。我试过一些json变形金刚比如jolt。但是没有达到预期的效果。

我使用的颠簸变换如下：

[
  {
    "operation": "shift",
    "spec": {
      "customer": {
        "*": {
          "@": "&"
        }
      }
    }
  }
]

产生了输出

{
  "fname" : "akhil",
  "lname" : "kumar"
}

我需要实现的输入和预期输出如下所示:

{
  "customer": {
    "fname": "akhil",
    "lname": "kumar",
    .
    .
    .
  },
  "mappingvalues": {
    "fname": "firstname",
    "lname": "lastname",
    .
    .
    .
  }
}

##OUTPUT
{
  "customer": {
    "firstname": "akhil",
    "lastname": "kumar",
    .
    .
    .
  }
}

*有没有任何方法可以在使用或不使用jolt变换的情况下在nifi中实现相同的效果？使用groovy脚本也可以这样做吗？*请帮我同样的忙。

Answer 1

Groovy中带有递归映射的代码：

import groovy.json.JsonSlurper

def ff = session.get()
if(!ff)return

def json = ff.read().withReader("UTF-8"){r-> new JsonSlurper().parse(r) } 

def mappings = json.remove('mappingvalues')
def mapper(o, mappings){
    if(o instanceof Map){
        //json object. let's iterate it and do mapping
        o = o.collectEntries{k,v-> [ (mappings[k] ?: k), mapper(v,mappings) ] }
    }else if(o instanceof List){
        //map elements in array
        o = o.collect{v-> mapper(v,mappings) }
    }
    return o
}
json = mapper(json,mappings)

ff.write("UTF-8"){w-> new JsonBuilder(json).writeTo(w) }
REL_SUCCESS << ff