Method and apparatus for enabling near real time data analysis
A method and apparatus for enabling near real time analysis of data for a wireless communication network using dynamic allocation backend processing resources. The method comprises, at each of a plurality of distributed components of a data processing system, receiving data from at least one network element of the cellular communication network, parsing the received data to extract a subset of the received data, and forwarding the extracted subset of data to the dynamic allocation backend processing resources for analytical processing of the extracted subset of data for the wireless communication network.
1. A method comprising:
receiving, by a device, data from at least one network element of a cellular communication network;
identifying, in near-real time of receiving the data and by the device, at least one data element that is required to generate desired analytical data based on analyzing a plurality of data elements included in the data;
parsing, in near-real time and by the device, the data to extract a subset of the data,
the subset of the data being based on the identified at least one data element,
the subset of the data including at least one of:
information associated with a measured radio propagation delay, or
information associated with a received signal code power;
determining, in near-real time and by the device, geolocation information based on at least one of the information associated with the measured radio propagation delay or the information associated with the received signal code power included in the subset of the data; and
forwarding, in near-real time and by the device, the subset of the data and the geolocation information to processing resources for near-real time analytical processing of the subset of the data using the geolocation information,
the processing resources including at least one of:
public dynamic allocation processing resources,
private dynamic allocation processing resources,
community dynamic allocation processing resources,
hybrid dynamic allocation processing resources,
a shared processing resource, or
a centralized processing resource, and
the processing resources being included in a group of dynamically allocated processing resources,
the group of dynamically allocated processing resources being scaled, based on a demand for resources,
the subset of the data and the geolocation information being pre-processed to create pre-processed data, and
the pre-processed data being used to generate a response to a query for information associated with at least some of the pre-processed data.
2. The method of claim 1 , where the data includes all raw communication session data for all communication sessions of the at least one network element.
3. The method of claim 1 , where the subset of the data and the geolocation information are stored.
4. The method of claim 1 , where
the subset of the data is allocated to at least one processing resource of the processing resources, and
the pre-processed data is stored for subsequent near-real-time analysis.
5. The method of claim 4 , where the near-real-time analysis is performed based on a request from a client application.
6. The method of claim 1 , where the processing resources include cloud processing resources.
7. A system comprising:
one or more devices to:
receive data from at least one network element of a cellular communication network;
identify, in near-real time, at least one data element that is required to generate desired analytical data based on analyzing a plurality of data elements included in the data;
parse, in near-real time, the data to extract a subset of the data,
the subset of the data being based on the identified at least one data element,
the subset of the data including at least one of:
information associated with a measured radio propagation delay, or
information associated with a received signal code power;
determine, in near-real time, geolocation information based on at least one of the information associated with the measured radio propagation delay or the information associated with the received signal code power included in the subset of the data; and
forward, in near-real time, the subset of the data and the geolocation information to processing resources for near-real time analytical processing of the subset of the data using the geolocation information,
the processing resources including at least one of:
public dynamic allocation processing resources,
private dynamic allocation processing resources,
community dynamic allocation processing resources,
hybrid dynamic allocation processing resources,
a shared processing resource, or
a centralized processing resource, and
the processing resources being included in a group of dynamically allocated processing resources,
the group of dynamically allocated processing resources being scaled, based on a demand for resources,
the subset of the data and the geolocation information being pre-processed to create pre-processed data, and
the pre-processed data being used to generate a response to a query for information associated with at least some of the pre-processed data.
8. A device comprising:
a memory to store instructions; and
a processor to execute the instructions to:
receive data from at least one network element of a cellular communication network;
identify, in near-real time, at least one data element that is required to generate desired analytical data based on analyzing a plurality of data elements included in the data;
parse, in near-real time, the data to extract a subset of the data,
the subset of the data being based on the identified at least one data element,
the subset of the data including at least one of:
information associated with a measured radio propagation delay, or
information associated with a received signal code power;
determine, in near-real time, geolocation information based on at least one of the information associated with the measured radio propagation delay or the information associated with the received signal code power included in the subset of the data; and
forward, in near-real time, the subset of the data to processing resources for near-real time analytical processing of the subset of the data using the geolocation information,
the processing resources including at least one of:
public dynamic allocation processing resources,
private dynamic allocation processing resources,
community dynamic allocation processing resources,
hybrid dynamic allocation processing resources,
a shared processing resource, or
a centralized processing resource, and
the processing resources being included in a group of dynamically allocated processing resources,
the group of dynamically allocated processing resources being scaled, based on a demand for resources,
the subset of the data and the geolocation information being pre-processed to create pre-processed data, and
the pre-processed data being used to generate a response to a query for information associated with at least some of the pre-processed data.
9. A non-transitory computer-readable medium storing instructions, the instructions comprising:
one or more instructions which, when executed by a processor of a device, cause the processor to:
receive data from at least one network element of a cellular communication network;
identify, in near-real time, at least one data element that is required to generate desired analytical data based on analyzing a plurality of data elements included in the data;
parse, in near-real time, the data to extract a subset of the data,
the subset of the data being based on the identified at least one data element,
the subset of the data including at least one of:
information associated with a measured radio propagation delay, or
information associated with a received signal code power;
determine, in near-real time, geolocation information based on at least one of the information associated with the measured radio propagation delay or the information associated with the received signal code power included in the subset of the data; and
forward, in near-real time, the subset of the data to processing resources for near-real time analytical processing of the subset of the data using the geolocation information,
the processing resources including at least one of:
public dynamic allocation processing resources,
private dynamic allocation processing resources,
community dynamic allocation processing resources,
hybrid dynamic allocation processing resources,
a shared processing resource, or
a centralized processing resource, and
the processing resources being included in a group of dynamically allocated processing resources,
the group of dynamically allocated processing resources being scaled, based on a demand for resources,
the subset of the data and the geolocation information being pre-processed to create pre-processed data, and
the pre-processed data being used to generate a response to a query for information associated with at least some of the pre-processed data.
10. The system of claim 7 , where
the subset of the data is allocated to at least one processing resource of the processing resources, and
the pre-processed data is stored for subsequent near-real-time analysis.
11. The system of claim 10 , where the near-real-time analysis is performed based on a request from a client application.
12. The device of claim 8 , where
the subset of the data is allocated to at least one processing resource of the processing resources, and
the pre-processed data is stored for subsequent near-real-time analysis.
13. The device of claim 12 , where the near-real-time analysis is performed based on a request from a client application.
14. The non-transitory computer-readable medium of claim 9 , where
the subset of the data is allocated to at least one processing resource of the processing resources, and
the pre-processed data is stored for subsequent near-real-time analysis.
15. The non-transitory computer-readable medium of claim 14 , where the near-real-time analysis is performed based on a request from a client application.
16. The method of claim 1 , where the subset of data includes the information associated with the measured radio propagation delay.
17. The method of claim 1 , where the geolocation information is based on a signal strength measurement received from a mobile communication unit.
18. The method of claim 1 , where the geolocation information is based on a round-trip delay (RTD) measurement for a signal between a mobile communication unit and a base station.
19. The device of claim 8 , where the geolocation information is based on a signal strength measurement received from a mobile communication unit.
20. The device of claim 8 , where the geolocation information is based on a round-trip delay (RTD) measurements for a signal between a mobile communication unit and a base station.