Hi, @Matt Burgess! My sample formatted JSON file content (in original flow file JSON objects are separated by new line) {
"schemaNameSpace": "CPMCDM.com.bis.bss.cpm.event.schema",
"schemaName": "CpmCustomerChangeEvent",
"schemaVersion": "5.1.1",
"eventHeader": {
"CPMCDM.com.bis.bss.cpm.event.schema.cpmCustomerChangeEvent.EventHeader": {
"eventCreationTime": {
"CPMCDM.com.bis.bss.cpm.event.schema.cpmCustomerChangeEvent.Time": {
"timestamp": {
"string": "2018-04-03T23:08:38.652+03:00"
},
"timeZoneType": {
"string": "SYSTEM_TIME_ZONE"
},
"zoneName": {
"string": "Europe/Kiev"
}
}
},
"cpmInstanceHost": {
"string": "env6-cpm1.dbss.bis.ua"
},
"recordUniqueId": {
"string": "77ECA557BFA74C98B2792222C9C72CED"
}
}
},
"customerInformation": {
"CPMCDM.com.bis.bss.cpm.event.schema.cpmCustomerChangeEvent.CustomerInformation": {
"customerId": {
"string": "5A834B1C27DE4FAF9F038B370AA3DDA4"
},
"partyId": null
}
},
"genericInterfaceParameters": null,
"requestInfo": null,
"partyChangeResult": null
}{
"schemaNameSpace": "com.bis.bss.edm.eventDataEnrichment.schema",
"schemaName": "EventDataEnrichment",
"schemaVersion": "1.0.0",
"enrichedData": [
]
}
{
"schemaNameSpace": "CPMCDM.com.bis.bss.cpm.event.schema",
"schemaName": "CpmCustomerChangeEvent",
"schemaVersion": "5.1.1",
"eventHeader": {
"CPMCDM.com.bis.bss.cpm.event.schema.cpmCustomerChangeEvent.EventHeader": {
"eventCreationTime": {
"CPMCDM.com.bis.bss.cpm.event.schema.cpmCustomerChangeEvent.Time": {
"timestamp": {
"string": "2018-04-03T23:08:39.652+03:10"
},
"timeZoneType": {
"string": "SYSTEM_TIME_ZONE"
},
"zoneName": {
"string": "Europe/Kiev"
}
}
},
"cpmInstanceHost": {
"string": "env6-cpm1.dbss.bis.ua"
},
"recordUniqueId": {
"string": "72DEA157BFA74C98B2792222C0C11CBE"
}
}
},
"customerInformation": {
"CPMCDM.com.bis.bss.cpm.event.schema.cpmCustomerChangeEvent.CustomerInformation": {
"customerId": {
"string": "1E2234B1C27DE4FAF9F038B370AA3DBE4"
},
"partyId": null
}
},
"genericInterfaceParameters": null,
"requestInfo": null,
"partyChangeResult": null
}
{
"schemaNameSpace": "CPMCDM.com.bis.bss.cpm.event.schema",
"schemaName": "CpmCustomerChangeEvent",
"schemaVersion": "5.1.1",
"eventHeader": {
"CPMCDM.com.bis.bss.cpm.event.schema.cpmCustomerChangeEvent.EventHeader": {
"eventCreationTime": {
"CPMCDM.com.bis.bss.cpm.event.schema.cpmCustomerChangeEvent.Time": {
"timestamp": {
"string": "2018-04-03T23:08:40.652+02:20"
},
"timeZoneType": {
"string": "SYSTEM_TIME_ZONE"
},
"zoneName": {
"string": "Europe/Kiev"
}
}
},
"cpmInstanceHost": {
"string": "env6-cpm1.dbss.bis.ua"
},
"recordUniqueId": {
"string": "55CBA557BFA74C98B2792222C9A11CDE"
}
}
},
"customerInformation": {
"CPMCDM.com.bis.bss.cpm.event.schema.cpmCustomerChangeEvent.CustomerInformation": {
"customerId": {
"string": "1E244B1C27DE4FAF9F038B370AA3DDD5"
},
"partyId": null
}
},
"genericInterfaceParameters": null,
"requestInfo": null,
"partyChangeResult": null
}{
"schemaNameSpace": "com.bis.bss.edm.eventDataEnrichment.schema",
"schemaName": "EventDataEnrichment",
"schemaVersion": "1.0.0",
"enrichedData": [
]
}
<br> Important thing to notice here is that some of the JSON objects in the flow file contain extention seperated with ESC (\x1b). {
"schemaNameSpace": "com.bis.bss.edm.eventDataEnrichment.schema",
"schemaName": "EventDataEnrichment",
"schemaVersion": "1.0.0",
"enrichedData": [
]
}<br> Schema looks like below: {mainJSON}{extentionJSON} {mainJSON} {mainJSON}{extentionJSON}
..... In the output I would like to have the following format: mainJSON | extentionJSON mainJSON | mainJSON | extentionJSON etc... Thank you!
... View more
