| CPC G06F 9/542 (2013.01) [G06F 9/44526 (2013.01)] | 15 Claims |
|
1. A method comprising:
accessing, by one or more processors, a data event, at a first data stream;
executing a plug-in to perform a first analysis comprising applying a first modification to the data event using a first function, the first modification implementing a first data modification rule on the data event, and applying a second modification to the data event using a second function, the second modification implementing a first data enrichment rule on the data event;
splitting the data event such that a copy of the data event is sent to a second data stream for parallel processing with the data event at the first data stream;
while simultaneously processing the data event at the first data stream, performing a second analysis comprising applying a third modification on the copy of the data event using a third function, the third modification implementing a second data modification rule on the copy of the data event, the second data modification rule being specific to a destination associated with the copy of the data event, and applying a fourth modification to the copy of the data event, the fourth modification implementing a second data enrichment rule on the copy of the data event using a fourth function, the second data enrichment rule being specific to the destination;
determining, based on analyzing the one or more processing rules, whether to forward the copy of the data event to the destination by filtering out redundant calls to the destination to reduce computer resources including bandwidth required to process the data event; and
based on one determining that the copy of the data event contains a monitored change that renders forwarding necessary, forwarding the copy of the data event to the destination after the applying of the fourth modification.
|