question NiFi - JOLT set defaults within an array in Support Questions

NiFi - JOLT set defaults within an array

justenji — Wed, 26 Jun 2019 18:07:16 GMT

Hi, I need some help with JOLT-syntax.

JSON-Input

{
  "nummer": "22",
  "id": "177",
  "table": [
    {
      "zn": 1,
      "stfflbisart": 10
    },
    {
      "zn": 2,
      "stfflbisart": 50
    }
  ]
}

JOLT-Specification

[{
    "operation": "shift",
    "spec": {
      "id": "ID",
      "nummer": "Nummer",
      "table": {
        "*": {
          "zn": "ArtikelPreise_Pos.[#2].ZeileNr",
          "stfflbisart": "ArtikelPreise_Pos.[#2].StaffelBis"
        }
      }
    }
}, {
    "operation": "default",
    "spec": {
      "Default_Kopf": "${VAR_KD}"
    }
    }
]

JSON-Output

{
  "ID" : "177",
  "Nummer" : "22",
  "ArtikelPreise_Pos" : [ {
    "ZeileNr" : 1,
    "StaffelBis" : 10
  }, {
    "ZeileNr" : 2,
    "StaffelBis" : 50
  } ],
  "Default_Kopf" : "${DFT_KOPF}"
}

Like in "Default_Kopf" I need to set a default value to each element of the array "ArtikelPreise_Pos" coming from flowfile attribute "DFT_POS".

The result should look like this:

WANTED JSON-Output

{
  "ID" : "177",
  "Nummer" : "22",
  "ArtikelPreise_Pos" : [ {
    "ZeileNr" : 1,
    "StaffelBis" : 10,
    "Default_Pos" : "${DFT_POS}"
  }, {
    "ZeileNr" : 2,
    "StaffelBis" : 50,
    "Default_Pos" : "${DFT_POS}"
  } ],
  "Default_Kopf" : "${VAR_KD}"
}

Tried things like this, but it doesn't work:

[{
    "operation": "shift",
    "spec": {
      "id": "ID",
      "nummer": "Nummer",
      "table": {
        "*": {
          "zn": "ArtikelPreise_Pos.[#2].ZeileNr",
          "stfflbisart": "ArtikelPreise_Pos.[#2].StaffelBis"
        }
      }
    }
}, {
    "operation": "default",
    "spec": {
      "Default_Kopf": "${DFT_KOPF}",
      "ArtikelPreise_Pos": {
        "Default_Pos": "${DFT_POS}"
      }
    }
      }
]

Any help? Thanks.

Re: NiFi - JOLT set defaults within an array

Shu_ashu — Thu, 27 Jun 2019 02:29:59 GMT

Try with below jolt spec:

[{
    "operation": "shift",
    "spec": {
      "id": "ID",
      "nummer": "Nummer",
      "table": {
        "*": {
          "zn": "ArtikelPreise_Pos.[#2].ZeileNr",
          "stfflbisart": "ArtikelPreise_Pos.[#2].StaffelBis"
        }
      }
    }
}, {
    "operation": "default",
    "spec": {
      "Default_Kopf": "${VAR_KD}",
      "ArtikelPreise_Pos[]": {
        "*": {
          "Default_Kopf": "${DFT_POS}"
        }
      }
    }
    }
]

Output:

{
  "ID" : "177",
  "Nummer" : "22",
  "ArtikelPreise_Pos" : [ {
    "ZeileNr" : 1,
    "StaffelBis" : 10,
    "Default_Kopf" : "${DFT_POS}"
  }, {
    "ZeileNr" : 2,
    "StaffelBis" : 50,
    "Default_Kopf" : "${DFT_POS}"
  } ],
  "Default_Kopf" : "${VAR_KD}"
}

I hope this matches with your expected output.

If the answer is helpful to resolve the issue, Login and Click on Accept button below to close this thread.This will help other community users to find answers quickly 🙂

Re: NiFi - JOLT set defaults within an array

justenji — Thu, 27 Jun 2019 12:59:38 GMT

@Shu Oh, so simple... thank you so much!