System and method for integrating observer capability without latency via dynamic application of cutomizable event templates and centralized validations

1 . A method for performing dynamic observations of inter-domain event processing in real-time, the method comprising:

receiving, via a processor and at an upstream application, an inter-domain event;

serializing, via the upstream application executed by the processor, the inter-domain event;

transmitting, via the upstream application to an event streaming platform, the serialized inter-domain event as a data stream;

extracting, by the event streaming platform, a topic for the serialized inter-domain event;

transmitting, by the event streaming platform, the serialized inter-domain event;

identifying, via an observer application executed by the processor, a workflow corresponding to the identified topic;

deserializing, via the observer application executed by the processor, the serialized inter-domain event;

applying, via the observer application executed by the processor, an event template corresponding to the deserialized inter-domain event;

based on the applying of the event template and via the observer application executed by the processor, dynamically identifying and applying a corresponding rule set without first requiring storage of the inter-domain event as a data object;

capturing, by the observer application executed by the processor, attributes corresponding to the inter-domain event based on the applied rule set; and

storing, in a database, a data record of the inter-domain event with the captured attributes.

2 . The method according to claim 1 , further comprising:

validating, by the observer application executed by the processor, each operation of the workflow was successfully performed or not.

3 . The method according to claim 1 , further comprising:

validating, by the observer application executed by the processor, each of the applied rule set for determining whether each rule in the applied rule set was violated or not.

4 . The method according to claim 1 , wherein the event template is customizable for capturing differing attributes of the inter-domain event without requiring a change to an underlying application.

5 . The method according to claim 1 , wherein the observer application is configured to centrally perform all validations for the inter-domain event processing.

6 . The method according to claim 1 , wherein the observer application is a third party to the upstream application and a downstream application that is to consume the data stream transmitted by the upstream application.

7 . The method according to claim 1 , further comprising:

building, by the event streaming platform, a data pipeline for the serialized inter-domain event; and

transmitting, by the event streaming platform and to a downstream application, the serialized inter-domain event for consumption by the downstream application.

8 . The method according to claim 7 , wherein the event streaming platform contemporaneously transmits the serialized inter-domain event to both the observer application and the downstream application.

9 . The method according to claim 1 , wherein the event template creates at least one restriction.

10 . The method according to claim 1 , wherein the event template creates at least one requirement.

11 . The method according to claim 1 , wherein the event template replaces at least one attribute with another attribute.

12 . The method according to claim 1 , further comprising:

deriving, by the processor, at least one additional attribute based on the captured attributes.

13 . The method according to claim 1 , wherein an amount of the attributes captured is minimal to prevent creating data latency.

14 . The method according to claim 1 , wherein the attributes are captured dynamically based on the applied rule set.

15 . The method according to claim 1 , wherein at least one attribute is captured based on a violation of the identified workflow.

16 . The method according to claim 1 , further comprising:

generating, by the processor, a plurality of vectors greater than three based on the captured attributes;

identifying, by the processor, a plurality of historical data records based on the plurality of vectors;

first training, by the processor, a machine learning (ML) model using the plurality of vectors and the plurality of historical data records identified; and

applying, by the processor, the first trained ML model on the inter-domain event and generating a prediction of an outcome of the inter-domain event.

17 . The method according to claim 16 , further comprising:

tracking, by the processor, a result of the inter-domain event;

comparing, by the processor, the result with the predicted outcome;

providing, by the processor, a correction to the result when the result is different from the predicted outcome; and

second training, by the processor, the first trained ML model with the correction.

18 . The method according to claim 1 , further comprising:

generating, by the processor, a report of the data record of the inter-domain event with the captured attributes.

19 . A system for performing dynamic observations of inter-domain event processing in real-time, the system comprising:

a processor configured to execute one or more applications; and

a memory operatively connected to the processor via a communication interface, the memory storing computer readable instructions, when executed, causes the processor to:

receive, at an upstream application, an inter-domain event;

serialize, via the upstream application, the inter-domain event;

transmit, from the upstream application to an event streaming platform, the serialized inter-domain event as a data stream;

extract, by the event streaming platform, a topic for the serialized inter-domain event;

transmit, by the event streaming platform, the serialized inter-domain event;

identify, at an observer application, a workflow corresponding to the identified topic;

deserialize, at the observer application, the serialized inter-domain event;

apply, via the observer application, an event template corresponding to the deserialized inter-domain event;

based on the event template applied and by the observer application, dynamically identify and apply a corresponding rule set without first requiring storage of the inter-domain event as a data object;

capture, via the observer application, attributes corresponding to the inter-domain event based on the applied rule set; and

store, in a database, a data record of the inter-domain event with the captured attributes.

20 . A non-transitory computer readable medium configured to store instructions for performing dynamic observations of inter-domain event processing in real-time, the instructions, when executed, cause a processor to perform the following:

receive, at an upstream application, an inter-domain event;

serialize, via the upstream application, the inter-domain event;

transmit, from the upstream application to an event streaming platform, the serialized inter-domain event as a data stream;

extract, by the event streaming platform, a topic for the serialized inter-domain event;

transmit, by the event streaming platform, the serialized inter-domain event;

identify, at an observer application, a workflow corresponding to the identified topic;

deserialize, at the observer application, the serialized inter-domain event;

apply, via the observer application, an event template corresponding to the deserialized inter-domain event;

based on the event template applied and by the observer application, dynamically identify and apply a corresponding rule set without first requiring storage of the inter-domain event as a data object;

capture, via the observer application, attributes corresponding to the inter-domain event based on the applied rule set; and

store, in a database, a data record of the inter-domain event with the captured attributes.