如何在输入JSON到JOLT规范中添加特定字段以在NIFI中获得所需的输出?

我无法使数据正确排列。

输入:

{    "type":"insert","timestamp":1578899080000,"columns":[
      {
         "id":1,"name":"id","column_type":4,"value":3
       },{
         "id":2,"name":"title","column_type":-1,"value":"mr"
       },{
         "id":3,"name":"first","value":"todd"
       },{
         "id":4,"name":"last","value":"graham"
       },{
         "id":5,"name":"street","value":"5760 spring hill rd"
       },{
         "id":6,"name":"city","value":"garden grove"
       },{
         "id":7,"name":"state","value":"north carolina"
       },{
         "id":8,"name":"zip","value":"81790"
       },{
         "id":9,"name":"gender","value":"M"
       },{
         "id":10,"name":"email","value":"todd.graham39@example.com"
       },{
         "id":11,"name":"username","value":"purplekoala484"
       },{
         "id":12,"name":"password","value":"paintball"
       },{
         "id":13,"name":"phone","value":"(230)-874-6532"
       },{
         "id":14,"name":"cell","value":"(186)-529-4912"
       },{
         "id":15,"name":"ssn","value":"362-31-5248"
       },{
         "id":16,"name":"date_of_birth","column_type":93,"value":"2006-07-25 05:48:01.0"
       },{
         "id":17,"name":"reg_date","value":"2004-12-05 11:26:34.0"
       },{
         "id":18,"name":"large","value":"http://api.randomuser.me/portraits/men/39.jpg"
       },{
         "id":19,"name":"medium","value":"http://api.randomuser.me/portraits/med/men/39.jpg"
       },{
         "id":20,"name":"thumbnail","value":"http://api.randomuser.me/portraits/thumb/men/39.jpg"
       },{
         "id":21,"name":"version","value":"0.6"
       },{
         "id":22,"name":"nationality","value":"US"
       }
    ] }

所需的输出:

[
   {
      "type":"insert","id":6,"title":"miss","first":"Amaira","last":"khan","street":"4524 hogan st","city":"iowa park","state":"ohio","zip":"24140","gender":"M","email":"guy.mckinney53@example.com","username":"blueduck623","password":"office","phone":"(309)-556-7859","cell":"(856)-764-9146","ssn":"973-37-9077","date_of_birth":"1983-11-03 22:02:12.0","reg_date":"2003-10-20 07:23:06.0","large":"http://api.randomuser.me/portraits/men/24.jpg","medium":"http://api.randomuser.me/portraits/med/men/24.jpg","thumbnail":"http://api.randomuser.me/portraits/thumb/men/24.jpg","version":"0.6","nationality":"US"

}
]
zyfv002 回答:如何在输入JSON到JOLT规范中添加特定字段以在NIFI中获得所需的输出?

以下规范将满足您的要求@(1,name)使用值作为键

[
  {
    "operation": "shift","spec": {
      "type": "[0].type","timestamp": "[0].timestamp","columns": {
        "*": {
          "value": "[0].@(1,name)"
        }
      }
    }
  }
]
本文链接:https://www.f2er.com/2679439.html

大家都在问