MME writer and identity service for ran parser
A method includes receiving data from one or more of (i) a data stream from one or more sources and (ii) a file, wherein the one or more sources are from systems associated with a mobile network; analyzing and summarizing relevant information from the data stream, wherein the relevant information includes data associated with user identities; transforming the relevant information included into a common output format, wherein the common output format is a same format for one or more vendor's equipment and one or more wireless technologies; and storing the relevant information in in-memory storage.
1 . A method comprising steps of:
receiving data from (i) a data stream from one or more sources or (ii) one or more files, wherein the one or more sources and the one or more files are from systems associated with a mobile network and comprise call trace messages in a plurality of vendor-specific formats corresponding to a plurality of different wireless technologies;
analyzing and summarizing relevant information from the data stream, wherein the relevant information includes data associated with user identities and is processed in near real time by a vendor- and technology-agnostic radio access network parser;
transforming the relevant information into a vendor- and technology-agnostic common output format, wherein the common output format is a same format for one or more vendor's equipment and one or more wireless technologies; and
storing the relevant information in in-memory storage comprising an in-memory data structure store used as a database or cache.
2 . The method of claim 1 , wherein the steps further include:
receiving a query from a service for identity values; and
utilizing a key from the query to obtain the identity values from the in-memory storage, the key comprising a combination of a time slot indicating a time bucket and one or more procedure identifiers associated with network elements, the identity values being stored as key/value data in the in-memory storage.
3 . The method of claim 2 , wherein the service is configured to process Call Trace Messages, and the query relates to a user associated with the Call Trace Messages.
4 . The method of claim 2 , wherein the service performs the query responsive to associated Call Trace Messages failing to include the identity values.
5 . The method of claim 1 , wherein the one or more sources include any of Mobile Management Entity (MME) data, probe data, and third party data.
6 . The method of claim 1 , wherein the receiving utilizes a message queue.
7 . The method of claim 1 , wherein the receiving, the analyzing and summarizing, the transforming, and the storing is performed at an edge of the mobile network.
8 . The method of claim 1 , wherein the steps further include:
determining an alignment of procedures based on the relevant information.
9 . The method of claim 1 , wherein the in-memory storage includes any of an encrypted and unencrypted format for the relevant data.
10 . The method of claim 1 , wherein the transforming includes synchronization of timestamps by computing a timestamp difference between a current timestamp and a minimum timestamp for a period and associating the timestamp difference with an identifier of an MME writer instance, the timestamp difference and an identifier being stored as synchronization data in the in-memory storage for use by a link generation service to determine whether identity data related to a message being processed is already available.
11 . The method of claim 1 , wherein the in-memory storage includes storage of keys and values.
12 . A processing system comprising:
one or more processors; and
memory storing instructions for programming the one or more processors to
receive data from (i) a data stream from one or more sources or (ii) one or more files, wherein the one or more sources and the one or more files are from systems associated with a mobile network and comprise call trace messages in a plurality of vendor-specific formats corresponding to a plurality of different wireless technologies;
analyze and summarize relevant information from the data stream, wherein the relevant information includes data associated with user identities and is processed in near real time by a vendor- and technology-agnostic radio access network parser;
transform the relevant information into a vendor- and technology-agnostic common output format, wherein the common output format is a same format for one or more vendor's equipment and one or more wireless technologies; and
store the relevant information in in-memory storage comprising an in-memory data structure store used as a database or cache.
13 . The processing system of claim 12 , wherein the instructions further program the one or more processors to:
receive a query from a service for identity values; and
utilize a key from the query to obtain the identity values from the in-memory storage, the key comprising a combination of a time slot indicating a time bucket and one or more procedure identifiers associated with network elements, the identity values being stored as key/value data in the in-memory storage.
14 . The processing system of claim 12 , wherein the one or more sources include any of Mobile Management Entity (MME) data, probe data, and third party data.
15 . The processing system of claim 12 , wherein the receiving utilizes a message queue.
16 . The processing system of claim 12 , wherein the receiving, the analyzing and summarizing, the transforming, and the storing is performed at an edge of the mobile network.
17 . The processing system of claim 12 , wherein the instructions further program the one or more processors to:
determining an alignment of procedures based on the relevant information.
18 . The processing system of claim 12 , wherein the in-memory storage includes any of an encrypted and unencrypted format for the relevant data.
19 . A non-transitory computer-readable medium comprising instructions for programming one or more processors to perform steps of:
receiving data from (i) a data stream from one or more sources or (ii) one or more files, wherein the one or more sources and the one or more files are from systems associated with a mobile network and comprise call trace messages in a plurality of vendor-specific formats corresponding to a plurality of different wireless technologies;
analyzing and summarizing relevant information from the data stream, wherein the relevant information includes data associated with user identities and is processed in near real time by a vendor- and technology-agnostic radio access network parser;
transforming the relevant information Includes-into a vendor- and technology-agnostic common output format, wherein the common output format is a same format for one or more vendor's equipment and one or more wireless technologies; and
storing the relevant information in in-memory storage comprising an in-memory data structure store used as a database or cache.
20 . The transitory computer-readable medium of claim 19 , wherein the steps further include:
receiving a query from a service for identity values; and
utilizing a key from the query to obtain the identity values from the in-memory storage, the key comprising a combination of a time slot indicating a time bucket and one or more procedure identifiers associated with network elements, the identity values being stored as key/value data in the in-memory storage.