AMS Event Processor Ingestion
The Event Processor Ingestion is a form of External Ingestion (Processor) that is used to ingest single or bulk data that comes in a particular payload via CSV Debulking or through EventStore and Adapter Microservices.
You can check the Configuration for the Transact Ingester at:
- Docker: AMS - Configuration → AMS - Docker Configuration → Event Processor (tab)
- Azure: AMS - Configuration → AMS - Azure Configuration → amsAccAggIngester (tab)
- AWS: AMS Configuration → AMS - AWS Configuration → EXTERNAL_INGESTER_CONFIG and LAMDA_CONFIG (tab)
The sample data that will be sent from the Adapter MS will be in the following format:
The arrangement payload contains the fields mentioned in the Events.
create_arrangement
{
"eventId": "8538b690-7d31-4fb0-90e4-3f9f22bd1cd8",
"dateTime": "2021-07-05T12:34:59.559+0000",
"correlationId": "8538b690-7d31-4fb0-90e4-3f9f22bd1cd8",
"status": "PROCESSED",
"eventSourceId": "ms-adapterservice",
"subject": "event",
"eventType": "create_arrangement",
"payload": {
"eventId": "81a0d623-0c8f-44d2-8c80-8b7697e4e372",
"dateTime": "2021-07-05T12:34:59.558+0000",
"status": "SUCCESS",
"eventSourceId": "ms-adapterservice",
"headers": {},
"eventType": "create_arrangement",
"payload": {
"arrangements": [
{
"extArrangementId": "GB0010001-AA123456",
"accountCategory": "6001",
"arrangementStatus": "AUTH",
"arrangementStatusDate": "2021-04-24",
"country": "GB",
"creationDate": "2021-04-15",
"currency": "USD",
"externalIndicator": "false",
"linkedReference": "GB0010001-122696",
"productLine": "ACCOUNTS",
"productGroup": "SAVINGS.ACCOUNT",
"isPortFolioAccount": false,
"iban": "GB58DEMO60161300122696",
"estmtEnabled": "false",
"company": {
"companyReference": "GB0010001"
},
"interests": [
{
"interestProperty": "CRINTEREST",
"paymentFrequency": "Monthly",
"effectiveRate": 2
}
],
"accountArrangement": {
"closureDate": "2021-04-24"
},
"roles": [
{
"partyId": "GB0010001-100100",
"partyRole": "OWNER"
}
],
"alternateReferences": [
{
"alternateType": "ACCOUNT",
"alternateId": "GB0010001-122696"
}
],
"extensionData": {
"arrangement": "test arrangement data"
}
}
]
}
}
}
update_arrangement
{
"eventId": "8538b690-7d31-4fb0-90e4-3f9f22bd1cd8",
"dateTime": "2021-07-05T12:34:59.559+0000",
"correlationId": "8538b690-7d31-4fb0-90e4-3f9f22bd1cd8",
"status": "PROCESSED",
"eventSourceId": "ms-adapterservice",
"subject": "event",
"eventType": "update_arrangement",
"payload": {
"eventId": "81a0d623-0c8f-44d2-8c80-8b7697e4e372",
"dateTime": "2021-07-05T12:34:59.558+0000",
"status": "SUCCESS",
"eventSourceId": "ms-adapterservice",
"headers": {},
"eventType": "update_arrangement",
"payload": {
"arrangements": [
{
"extArrangementId": "GB0010001-AA123456",
"accountCategory": "6006"
}
]
}
}
}
LikeBe the first to like this
No labelsEdit Labels
User icon: Add a picture of yourself
Write a comment…
Powered by Atlassian Confluence 7.4.4 (Cluster node: 3b17d5dc) Report a bug Atlassian News
Atlassian
Field Name
|
Application/Table name
In this topic