Data collection coordination and persistent storage control for analytics
Systems, methods, apparatuses, and computer program products for data collection coordination and persistent storage control for analytics. For example, certain embodiments may provide a unified data management framework that efficiently serves data collection and distribution needs and isolates a consumer from a producer. Further, some embodiments may provide for a reduction or elimination of unnecessary data storage in a data repository used in association with the data management framework provided by certain embodiments. Specifically, certain embodiments may allow a consumer entity that is requesting specific data to specify whether the data is to be kept in persistent storage in a data repository. The consumer entity, when requesting data, may send an indication that data is to be provided to the consumer entity only, that data is to be provided to the data repository only, or that the data is to be provided to the data repository and the consumer entity.
1 . An apparatus, comprising:
at least one processor; and
at least one memory storing computer program code, which, when executed by the at least one processor, causes the apparatus at least to perform:
receiving, from at least one consumer entity, at least one request for data, wherein the at least one request comprises at least one request for data related to at least one user equipment (UE);
determining a set of data sources that can provide the data, wherein the determining the set of data sources that can provide the data related to the at least one UE comprises querying, based on the at least one request, at least one other network entity to determine at least one network function serving the at least one UE;
ensuring that the data is provided from at least one data source of the set of data sources, the at least one data source comprising the at least one other network function; and
performing one or more control actions related to controlling how a messaging framework replicates or provides the data to the at least one consumer entity.
2 . The apparatus according to claim 1 , wherein the apparatus comprises a data collection and coordination function (DCCF), and wherein the at least one consumer entity comprises at least one network data analytics function (NWDAF).
3 . The apparatus according to claim 1 , wherein the ensuring that the data is collected from the at least one data source comprises:
determining whether the data is already being collected from the at least one data source.
4 . The apparatus according to claim 1 , wherein the determining whether the data is already being collected from the at least one data source-comprises:
processing information in at least one database to determine if the data is already being provided from the at least one data source.
5 . The apparatus according to claim 1 , wherein the ensuring that the data is collected from the at least one data source comprises:
requesting that the at least one data source start providing the data based on determining that the data is not already being provided from the at least one data source.
6 . The apparatus according to claim 1 , wherein the ensuring that the data is collected from the at least one data source comprises:
sending at least one data request or at least one subscription request to the at least one data source.
7 . The apparatus according to claim 6 , wherein the ensuring that the data is collected from the at least one data source further comprises:
receiving at least one acknowledgement of the at least one data request or at least one subscription request based on the sending the at least one data request or at least one subscription request.
8 . An apparatus, comprising:
at least one processor; and
at least one memory storing computer program code, which, when executed by the at least one processor, causes the apparatus at least to perform:
receiving, from at least one consumer entity, at least one request for data;
determining, based on querying at least one other network entity, whether the data is to be sent to the at least one consumer entity, at least one data repository, or both the at least one consumer entity and the at least one data repository;
determining a set of data sources that can provide the data;
ensuring that the data is collected from at least one data source of the set of data sources; and
performing one or more control actions related to controlling how a messaging framework replicates or provides the data to the at least one consumer entity in an instance the data is to be sent to the at least one consumer entity or both the at least one consumer entity and the at least one data repository.
9 . The apparatus according to claim 8 , wherein the apparatus comprises a data collection and coordination function (DCCF).
10 . The apparatus according to claim 8 , wherein the at least one consumer entity comprises at least one network data analytics function (NWDAF).
11 . The apparatus according to claim 8 , wherein the determining the set of data sources that can provide the data comprises:
querying at least one other network entity to determine at least one network function serving at least one user equipment (UE) based on the at least one request for the data, the at least one request for the data comprising at least one request for data related to the at least one UE.
12 . The apparatus according to claim 8 , wherein the ensuring that the data is collected from the at least one data source comprises:
determining whether the data is already being collected from the at least one data source.
13 . The apparatus according to claim 12 , wherein the determining whether the data is already being collected from the at least one data source comprises:
processing information in at least one database to determine if the data is already being provided from the at least one data source.
14 . The apparatus according to claim 8 , wherein the ensuring that the data is collected from the at least one data source, comprises:
requesting that the at least one data source start providing the data based on determining that the data is not already being provided from the at least one data source.
15 . The apparatus according to claim 8 , wherein the ensuring that the data is collected from the at least one data source comprises:
sending at least one data request or at least one subscription request to the at least one data source.
16 . The apparatus according to claim 15 , wherein the ensuring that the data is collected from the at least one data source further comprises:
receiving at least one acknowledgement of the at least one data request or at least one subscription request based on the sending the at least one data request or at least one subscription request.
17 . The apparatus according to claim 8 , wherein the one or more control actions comprises:
sending at least one subscription request to a messaging framework requesting sending of at least one notification to the at least one consumer entity, the at least one data repository, or both the at least one consumer entity and the at least one data repository, wherein the at least one notification is associated with the at least one request for the data.
18 . The apparatus according to claim 8 , wherein the computer program code, when executed by the at least one processor, further causes the apparatus at least to perform:
requesting that the at least one data source modify the data being supplied based on determining that the data is already being collected from the at least one data source.
19 . The apparatus according to claim 18 , wherein requesting comprises requesting a modification by the at least one data source to a granularity of the data.
20 . The apparatus according to claim 8 , wherein the computer program code, when executed by the at least one processor, further causes the apparatus at least to perform:
updating at least one database with information identifying one or more of the at least one data source providing the data, the data being provided, or a set of consumers receiving the data.
21 . The apparatus according to claim 8 , wherein the one or more control actions comprises:
sending a subscription request to a messaging framework requesting at least one notification be sent to the first consumer entity, a data lake, or both the first consumer entity and the data lake, wherein the at least one notification is associated with the request for the data.