The output of the JSON data after splitting JSON object:

Since we have a JSON array in the output of the JSON data, we need to split the JSON object to call the attributes easily, so we are splitting the JSON object into a single line object as above. If the specified JsonPath is not found or does not evaluate an array element, the original file is routed to 'failure,' and no files are generated. Each generated FlowFile is compressed of an element of the specified array and transferred to relationship 'split,' with the original file transferred to the 'original' relationship. Splits a JSON File into multiple, separate FlowFiles for an array element specified by a JsonPath expression.

Taking below JSON Data as Sample added in the properties tab and the custom text. We scheduled this processor to run every 60 sec in the Run Schedule and Execution as the Primary node. Schedule the GenerateFlow file processor as shown below.

This processor creates FlowFiles with random data or custom content. Here in this scenario, we will take sample multi-nested JSON data and convert multi-nested JSON data into a denormalized, flattened-out version of the CSV.

Install Ubuntu in the virtual machine Click Here.

Step 6: Configure the UpdateAttribute for an extension to file.

Step 1: Configure the GenerateFlow File.

Recipe Objective: How to convert multi-nested JSON files into denormalized, flattened-out versions of the CSV in NiFi?.

Convert nested json to csv python