@Techie123 maybe you can beautify it a bit 😄 import org.apache.commons.io.IOUtils
import java.nio.charset.StandardCharsets
import groovy.json.*
import java.util.ArrayList
def flowFile = session.get()
if (!flowFile) return
try {
flowFile = session.write(flowFile, {
inputStream,
outputStream ->
def text = IOUtils.toString(inputStream, StandardCharsets.UTF_8)
def content = new JsonSlurper().parseText(text)
for (int i = content.size() - 1; i >= 0; --i) {
int objNo = i
int recNo = i + 1
def rec = 'Record ' + recNo
if (rec != content[objNo].enrichment.Record) {
content.remove(content[objNo])
}
}
def jsonOutput = JsonOutput.toJson(content)
outputStream.write(JsonOutput.prettyPrint(jsonOutput).getBytes(StandardCharsets.UTF_8))
}
as StreamCallback)
session.transfer(flowFile, REL_SUCCESS)
} catch (Exception e) {
log.error('Error during JSON operations', e)
session.transfer(flowFile, REL_FAILURE)
}
... View more
