Systems and methods for network monitoring and testing using a generic data mediation platform
Embodiments are directed to systems and methods for network monitoring and testing using a generic data mediation platform between one or more probes and one or more dashboards. The generic data mediation platform performs data correlation, filtering enrichment and aggregation of events obtained from monitored networks.
1. A method of correlating one or more call legs of a Voice Over Internet Protocol (VoIP) call, comprising the steps of:
detecting a first call leg among the one or more call legs with a first network probe from a plurality of network probes, wherein the detecting a first call leg comprises describing the first call leg using a first event that includes a first plurality of fields, wherein the first plurality of fields includes at a least timestamp and an error code;
detecting a second call leg among the one or more call legs with a second network probe from the plurality of network probes, wherein the detecting a second call leg comprises describing the second call leg using a second event that includes a second plurality of fields, wherein the second plurality of fields includes at least a timestamp and an error code;
determining one or more relationships between the first call leg and a second call leg based on one or more complex event processing rules configured to parse the first plurality of fields and the second plurality of fields;
correlating the first call leg and the second leg based on a parsing of the first plurality of fields and the second plurality of fields with the one or more complex event processing rules;
identifying the first call leg and the second call leg as belonging to a single call based on the one or more relationships and the correlation; and
reporting the first call leg and the second leg as the single call when the timestamp and the error code in the first plurality of fields match the timestamp and the error code in the second plurality of fields.
2. A method of correlating one or more call legs of a Voice Over Internet Protocol (VoIP) call, comprising the steps of:
detecting a first call leg among the one or more call legs with a first network probe from a plurality of network probes, wherein the detecting a first call leg comprises describing the first call leg using a first event that includes a first plurality of fields, wherein the first plurality of fields includes at least timestamps, a caller phone number, and a called phone number;
detecting a second call leg among the one or more call legs with a second network probe from the plurality of network probes, wherein the detecting a second call leg comprises describing the second call leg using a second event that includes a second plurality of fields, wherein the second plurality of fields includes at least timestamps, a caller phone number, and a called phone number;
determining one or more relationships between the first call leg and a second call leg based on one or more complex event processing rules configured to parse the first plurality of fields and the second plurality of fields;
correlating the first call leg and the second leg based on a parsing of the first plurality of fields and the second plurality of fields with the one or more complex event processing rules;
identifying the first call leg and the second call leg as belonging to a single call based on the one or more relationships and the correlation; and
reporting the first call leg and the second leg as the single call when the timestamps, the caller phone number, and the called phone number in the first plurality of fields match the timestamps, the caller phone number, and the called phone number in the second plurality of fields.
3. The method of claim 2 , wherein the first plurality of fields and the second plurality of fields further comprise a call duration.
4. A non-transitory computer readable storage medium storing thereon computer executable instructions for a generic data mediation platform for a monitoring and testing of a network, the instructions comprising:
receiving a first data from a first network probe from a plurality of network probes, the first network probe generating the first data using a first format;
receiving a second data from a second network probe from the plurality of network probes, the second network probe generating the second data using a second format different from the first format;
determining a first data set and a first receiving data format requested by a first dashboard associated with a first party;
determining a second data set and a second receiving data format requested by a second dashboard associated with a second party, the second receiving data format being different from the first receiving data format, and wherein the first party and the second party are different;
converting the first data to the first receiving data format if the first format is different than the first receiving format and if the first data is included in the first data set;
converting the second data to the second receiving data format if the second format is different than the second receiving format and if the second data is included in the second data set;
converting the first data to the second receiving data format if the first format is different than the second receiving format and if the first data is included in the second data set;
converting the second data to the first receiving data format if the second format is different than the first receiving format and if the second data is included in the first data set;
sending the first data to the first dashboard and the second dashboard; and
sending the second data to the first dashboard and the second dashboard.
5. The non-transitory computer readable storage medium of claim 4 , wherein the converting the first data to the first receiving data format comprises generating key performance indicators based on the first data using and the first receiving data format.
6. A non-transitory computer readable storage medium storing thereon computer executable instructions for a generic data mediation platform for a monitoring and testing of a network, the instructions comprising:
receiving a first data from a first network probe from a plurality of network probes, the first network probe generating the first data using a first format, wherein the first network probe is associated with a third party;
receiving a second data from a second network probe from the plurality of network probes, the second network probe generating the second data using a second format different from the first format, wherein the second network probe is associated with a fourth party;
determining a first data set and a first receiving data format requested by a first dashboard associated with a first party, and wherein the first party and the third party are different;
determining a second data set and a second receiving data format requested by a second dashboard associated with a second party, the second receiving data format being different from the first receiving data format;
converting the first data to the first receiving data format if the first format is different than the first receiving format and if the first data is included in the first data set;
converting the second data to the second receiving data format if the second format is different than the second receiving format and if the second data is included in the second data set;
converting the first data to the second receiving data format if the first format is different than the second receiving format and if the first data is included in the second data set;
converting the second data to the first receiving data format if the second format is different than the first receiving format and if the second data is included in the first data set;
sending the first data to the first dashboard and the second dashboard; and
sending the second data to the first dashboard and the second dashboard.
7. The non-transitory computer readable storage medium of claim 6 , wherein the third party and the fourth party are different.
8. A non-transitory computer readable storage medium storing thereon computer executable instructions for a generic data mediation platform for a monitoring and testing of a network, the instructions comprising:
receiving a first data from a first network probe from a plurality of network probes, the first network probe generating the first data using a first format;
receiving a second data from a second network probe from the plurality of network probes, the second network probe generating the second data using a second format different from the first format;
determining a first data set and a first receiving data format requested by a first dashboard;
determining a second data set and a second receiving data format requested by a second dashboard, the second receiving data format being different from the first receiving data format;
converting the first data to the first receiving data format if the first format is different than the first receiving format and if the first data is included in the first data set;
converting the second data to the second receiving data format if the second format is different than the second receiving format and if the second data is included in the second data set;
converting the first data to the second receiving data format if the first format is different than the second receiving format and if the first data is included in the second data set;
converting the second data to the first receiving data format if the second format is different than the first receiving format and if the second data is included in the first data set;
sending the first data to the first dashboard and the second dashboard;
sending the second data to the first dashboard and the second dashboard;
generating a third data by correlating the first data and the second data; and
converting the third data to the first receiving data format or the second receiving data format.
9. The non-transitory computer readable storage medium of claim 8 , wherein the platform is further configured to add data from an external source to the third data.
10. The non-transitory computer readable storage medium of claim 8 , wherein the platform is further configured to allow an end-user to define one or more operations to which the first data and the second data are applied.
11. The non-transitory computer readable storage medium of claim 10 , wherein the one or more operations comprise any of data filtering, data normalization, data enrichment, data correlation, data aggregation, generation of key performance indicators, data thresholdings, and alerting.
12. The non-transitory computer readable storage medium of claim 10 , wherein the first network probe generates the first data asynchronously from the second network probe generating the second data.