DESC: FORM 2
THE PATENTS ACT, 1970
(39 of 1970)
&
THE PATENTS RULES, 2003
COMPLETE SPECIFICATION
(See section 10 and rule 13)
1. TITLE OF THE INVENTION
SYSTEM AND METHOD FOR DISTRIBUTING DATA TO ATLEAST ONE OF PLURALITY CONSUMER UNITS
2. APPLICANT(S)
NAME NATIONALITY ADDRESS
JIO PLATFORMS LIMITED INDIAN OFFICE-101, SAFFRON, NR. CENTRE POINT, PANCHWATI 5 RASTA, AMBAWADI, AHMEDABAD 380006, GUJARAT, INDIA
3.PREAMBLE TO THE DESCRIPTION
THE FOLLOWING SPECIFICATION PARTICULARLY DESCRIBES THE NATURE OF THIS INVENTION AND THE MANNER IN WHICH IT IS TO BE PERFORMED.

FIELD OF THE INVENTION
[0001] The present invention generally relates to data segregation, and more particularly relates to a system and method for distributing segregated data to the multiple feeds.
BACKGROUND OF THE INVENTION
[0002] Traditionally, for different consumer systems, the data feed could not be segregated on the fly without manual intervention and storage was required to segregate and storing the data in database. Also, after storing, legacy systems forward the data to different consumer systems based on their field requirements. Development efforts, testing, integration testing, and downtime at consumer end were needed to handle such scenarios.
[0003] In the legacy systems, it is not possible to segregate data into different consumer systems based on the policies. Consumer system may be one or more of a file system, and a distributed file system or the like.
[0004] If a new consumer system arrives, it cannot be integrated on the fly. A downtime is required and changes in the coding are required.
[0005] There is a need to overcome the above mentioned drawbacks.
SUMMARY OF THE INVENTION
[0006] One or more embodiments of the present disclosure provide a system and method for distributing data into a plurality of consumer units.
[0007] In one aspect of the present invention, a system for distributing data into a plurality of consumer units is disclosed. The system includes a receiving unit configured to receive a request from a User Interface (UI). In one embodiment, the request includes one or more policies. The receiving unit is also configured to receive data from at least one source unit of a plurality of source units. The system includes a segregation unit configured to segregate the received data from the at least one source unit based on the one or more policies received from the UI. The system further includes a transmitting unit configured to transmit the segregated data to a relevant consumer unit of the plurality of consumer units upon the segregation of the data based on the one or more policies. In an embodiment, the system includes a validation unit configured to validate the one or more policies included in the request received from the UI. Furthermore, the system includes a storage unit configured to store the one or more policies upon in a database based on the validation of the one or more policies.
[0008] In one embodiment, the segregation unit is configured to segregate the data in real time.
[0009] In one embodiment, based on the one or more policies, the data relevant to each of the plurality of consumer units is segregated.
[0010] In one embodiment, the plurality of source units is at least one of, a node, a server, a router.
[0011] In one embodiment, the plurality of consumer units is at least one of, a User Equipment, a network equipment.
[0012] In one embodiment, the data includes, but not limited to a Short Message Service (SMS), a call, a web page, an email message, a video stream.
[0013] In another aspect of the present invention, a method for distributing data to at least one of a plurality of consumer units is disclosed. The method includes the steps of receiving, by one or more processors, the request from the UI, the request includes one or more policies and also receiving, by the one or more processors, data from at least one source unit of the plurality of source units. The method includes the step of segregating, by the one or more processors, the received data from the at least one source unit based on the one or more policies received from the UI. The method includes the steps of transmitting, by the one or more processors, the segregated data to the relevant consumer unit from the plurality of consumer units upon the segregation of the data based on the one or more policies.
[0014] In another aspect of the invention, a non-transitory computer-readable medium having stored thereon computer-readable instructions is disclosed. The computer-readable instructions are executed by a processor. The processor is configured to receive, a request from a User Interface (UI), the request includes one or more policies. The processor is further configured to receive, data from at least one source unit of the plurality of source units. The processor is further configured to segregate, the received data from the at least one source unit based on the one or more policies received from the UI. The processor is further configured to transmit the segregated data to a relevant consumer unit of the plurality of consumer units upon the segregation of the data based on the one or more policies.
[0015] In another aspect of invention, User Equipment (UE) is disclosed. The UE includes one or more primary processors communicatively coupled to one or more processors, the one or more primary processors coupled with a memory. The processor is configured to transmit the request including one or more policies to the one or more processors.
[0016] Other features and aspects of this invention will be apparent from the following description and the accompanying drawings. The features and advantages described in this summary and in the following detailed description are not all-inclusive, and particularly, many additional features and advantages will be apparent to one of ordinary skill in the relevant art, in view of the drawings, specification, and claims hereof. Moreover, it should be noted that the language used in the specification has been principally selected for readability and instructional purposes and may not have been selected to delineate or circumscribe the inventive subject matter, resort to the claims being necessary to determine such inventive subject matter.
BRIEF DESCRIPTION OF THE DRAWINGS
[0017] The accompanying drawings, which are incorporated herein, and constitute a part of this disclosure, illustrate exemplary embodiments of the disclosed methods and systems in which like reference numerals refer to the same parts throughout the different drawings. Components in the drawings are not necessarily to scale, emphasis instead being placed upon clearly illustrating the principles of the present disclosure. Some drawings may indicate the components using block diagrams and may not represent the internal circuitry of each component. It will be appreciated by those skilled in the art that disclosure of such drawings includes disclosure of electrical components, electronic components or circuitry commonly used to implement such components.
[0018] FIG. 1 is an exemplary block diagram of an environment for distributing data to a plurality of consumer units, according to various embodiments of the present invention;
[0019] FIG. 2 is an exemplary architecture of a system for distributing data to the plurality of consumer units, according to various embodiments of the present invention;
[0020] FIG. 3 is a block diagram of the system for distributing data to the plurality of consumer units, according to various embodiments of the present invention;
[0021] FIG. 4 is schematic representation of a workflow of the system of FIG. 3, according to various embodiments of the present invention;
[0022] FIG. 5 is a signal flow diagram for distributing data to the plurality of consumer units, according to various embodiments of the present invention; and
[0023] FIG. 6 shows a flow diagram of a method for distributing data to the plurality of consumer units, according to various embodiments of the present invention.
[0024] The foregoing shall be more apparent from the following detailed description of the invention.
DETAILED DESCRIPTION OF THE INVENTION
[0025] Some embodiments of the present disclosure, illustrating all its features, will now be discussed in detail. It must also be noted that as used herein and in the appended claims, the singular forms "a", "an" and "the" include plural references unless the context clearly dictates otherwise.
[0026] Various modifications to the embodiment will be readily apparent to those skilled in the art and the generic principles herein may be applied to other embodiments. However, one of ordinary skill in the art will readily recognize that the present disclosure including the definitions listed here below are not intended to be limited to the embodiments illustrated but is to be accorded the widest scope consistent with the principles and features described herein.
[0027] A person of ordinary skill in the art will readily ascertain that the illustrated steps detailed in the figures and here below are set out to explain the exemplary embodiments shown, and it should be anticipated that ongoing technological development will change the manner in which particular functions are performed. These examples are presented herein for purposes of illustration, and not limitation. Further, the boundaries of the functional building blocks have been arbitrarily defined herein for the convenience of the description. Alternative boundaries can be defined so long as the specified functions and relationships thereof are appropriately performed. Alternatives (including equivalents, extensions, variations, deviations, etc., of those described herein) will be apparent to persons skilled in the relevant art(s) based on the teachings contained herein. Such alternatives fall within the scope and spirit of the disclosed embodiments.
[0028] As per various embodiments depicted, the present invention discloses the system and method for distributing data to at least one of a plurality of consumer units. The present invention enriches the data fields at a message broker level and segregating data feed into multiple feeds based on a consuming system. The method disclosed in the present invention requires no code level changes.
[0029] All the configurations/policies related to consumer systems may be done on the fly with the help of a User Interface (UI). The present invention also may be configured to reduce hardware infrastructure by avoiding storing incoming data in a database. The present invention is performed at an application level (micro-service level).
[0030] Referring to FIG. 1, FIG. 1 illustrates an exemplary block diagram of an environment 100 for distributing data to a plurality of consumer units 101, according to various embodiments of the present invention. In one embodiment, the plurality of consumer units 101 includes but are not limited to at least one of, a User Equipment (UE), a network equipment, the network equipment includes a Network Functions (NF) for example but not limited to Access and Mobility Management Function (AMF), Network Repository Function (NRF), Policy Control Function (PCF), Network Slice Selection Function (NSSF), User Plane Function (UPF) and so on. In one embodiment, the plurality of consumer units further includes at least one of, but not limited to, a Network Management unit, a reporting engine, a Machine Learning (ML)The environment 100 includes the plurality of consumer units 101, a network 102, a source unit 103, a system 104, a User Equipment (UE) 105 and a server 106. In one embodiment, at least one UE 105 is configured to at least transmit a request including one or more policies to the system 104 for distributing data to the plurality of consumer units 101. In one embodiment, the at least one UE 105a is at least one of a first UE 105a and a second UE 105b. At least one UE 105a is at least one of the first UE 105a and the second UE 105b are communicatively connected to the system 104 via the network 102. The first UE 105a and the second UE 105b will henceforth collectively and individually be referred to as “the UE 105” without limiting the scope and deviating from the scope of the present disclosure.
[0031] More information regarding the same will be provided with reference to the following figures.
[0032] In one embodiment, the UE 105 includes, but are not limited to, a handheld wireless communication device (e.g., a mobile phone, a smart phone, a tablet device, and so on), a wearable computer device (e.g., a head-mounted display computer device, a head-mounted camera device, a wristwatch computer device, and so on), a Global Positioning System (GPS) device, a laptop computer, a tablet computer, or another type of portable computer, a media playing device, a portable gaming system, and/or any other type of computer device with wireless communication capabilities, and the like.
[0033] The environment 100 further includes the server 106 communicably coupled to the UE 105 via the network 102. The server 106 includes by way of example but not limitation, one or more of a standalone server, a server blade, a server rack, a bank of servers, a server farm, hardware supporting a part of a cloud service or system, a home server, hardware running a virtualized server, one or more processors executing code to function as a server, one or more machines performing server-side functionality as described herein, at least a portion of any of the above, some combination thereof. In an embodiment, the entity may include, but is not limited to, a vendor, a network operator, a company, an organization, a university, a lab facility, a business enterprise, a defence facility, or any other facility that provides content.
[0034] The network 102 includes, by way of example but not limitation, one or more of a wireless network, a wired network, an internet, an intranet, a public network, a private network, a packet-switched network, a circuit-switched network, an ad hoc network, an infrastructure network, a Public-Switched Telephone Network (PSTN), a cable network, a cellular network, a satellite network, a fiber optic network, or some combination thereof. The network 102 may include, but is not limited to, a Third Generation (3G), a Fourth Generation (4G), a Fifth Generation (5G), a Sixth Generation (6G), a New Radio (NR), a Narrow Band Internet of Things (NB-IoT), an Open Radio Access Network (O-RAN), and the like.
[0035] Further, the network 102 also includes, by the way of example but not limitation, one or more wireless interfaces/protocols such as, for example, 802.11 (Wi-Fi), 802.15 (including Bluetooth™), 802.16 (Wi-Max), 802.22, Cellular standards such as CDMA, CDMA2000, WCDMA, Radio Frequency (e.g., RFID), Infrared, laser, Near Field Magnetics, etc.
[0036] The environment 100 further includes the system 104 communicably coupled to the plurality of consumer units 101, the source unit 103 and the UE 105 via the network 102. The system 104 is configured for distributing data to the plurality of consumer units 101. Further, the system 104 is adapted to be embedded within the server 106 or is embedded as the individual entity independent of the server 106. However, for the purpose of description, the system 104 is described as an integral part of the server 106, without deviating from the scope of the present disclosure.
[0037] Operational and construction features of the system 104 will be explained in detail with respect to the following figures.
[0038] Referring to FIG. 2, FIG. 2 is an exemplary architecture of the system 104 for distributing data to the plurality of consumer units 101, according to various embodiments of the present invention. The architecture of the system 104 includes the source unit 103, the system 104, a User Interface (UI) 201, the plurality of consumer unit 101 and a database 220. The user transmits the request including one or more policies from the UI 210 to the system 104 for policy provisioning. The system 104 further receives the data from a first source system 103a and a second source system 103b of the plurality of source unit 103. In one embodiment, the plurality of source unit 103 includes the first source system 103a and the second source system 103b. In an alternate embodiment, the source unit 103 is not limited to the first source system 103a and the second source system 103b, may include multiple of source system 103. In one embodiment, the plurality of source units 103 includes but not limited to at least one of, a node, a server 106, a router, a producer, a publisher, service provider.
[0039] In one embodiment, the system 104 further receives the data received from the source unit 103 includes, but not limited to a Short Message Service (SMS), a call, a web page, an email message, a video stream. In an alternate embodiment, the data received from the source unit 103 may also include an alarm, a counter, a clear code, a Fault, Configuration, Accounting, Performance and Security (FCAPS), Key Performance Indicators (KPIs), probing agent records, logs, trace data Call Detail Record (CDR), Metric data so on.
[0040] Furthermore, the system 104 is configured to validate the one or more policies included in the received request from the UI 201 and store the one or more policies in the database 220 based on the successful validation of the one or more policies.
[0041] Accordingly, the system 104 receives the data from the source unit 103 to segregate the data. The segregation of the data is done based on the stored one or more policies in the database 220. The data relevant to each of the plurality of consumer units 101 is segregated based on the one or more policies.
In one embodiment, for example, one or more policies include, but is not limited to, a Quality of Service (QoS) Policies, a routing policies, security policies, an Access Control Policies (ACP), a Traffic Management Policies (TMP), a Resource Allocation Policies (RAP) and so on. In one embodiment, the QoS policy ensure consistent performance in receiving the necessary bandwidth and priority to operate effectively during network congestion. The routing policy determine an optimal path based on cost, latency, or reliability in network congestion. The security policy protects the network from unauthorized access and malicious activity. The ACP restrict access to certain servers or data based on user roles or Internet protocol (IP) addresses. The TMP includes but not limited to bandwidth throttling, traffic shaping, or load balancing policies to optimize network performance. The RAP manages the allocation of network resources.
[0042] The system 104 further transmits the segregated data to the plurality of consumer units 101 upon the segregation of the data based on the one or more policies. The plurality of consumer units 101 includes a first consumer system 101a, a second consumer system 101b and a third consumer system 101c. In one embodiment, the data is segregated in real time. In an alternate embodiment, the consumer unit 101 is not limited to the first consumer system 101a, the second consumer system 101b and the third consumer system 101c, may also include multiple consumer unit 101. In one embodiment, the plurality of consumer units 101 includes but not limited to at least one of, a User Equipment (UE), a network equipment, and an Application programming interface (API). In one embodiment, the API refers to a component or network function sending an request to retrieve or consume data from the source units.
[0043] In one embodiment, the network equipment includes a Network Functions (NF) for example but not limited to Access and Mobility Management Function (AMF), Network Repository Function (NRF), Policy Control Function (PCF), Network Slice Selection Function (NSSF), User Plane Function (UPF) and so on. In one embodiment, the network equipment also includes but not limited to a switches, routers, a wireless access points, a wireless LAN controller and so on.
[0044] In one embodiment, the system 104 transmit the relevant segregated data to the first consumer system 101a, the second consumer system 101b and the third consumer system 101c accordingly. In an embodiment, the system 104 transmits the segregated data without storing the data in the database 220 based on the consumer systems 103 specific provisioned policies. The UI 201 based configuration/policies approach ensure that relevant data are transmitted to the first consumer system 101a, the second consumer system 101b and the third consumer system 101c respectively on the basis of their policies.
[0045] Referring to FIG. 3, FIG. 3 illustrates a block diagram of the system 104 for distributing data to the plurality of consumer units 101, according to various embodiments of the present invention. The system 104 includes the processor 302, a memory 304, a user interface 306, a display unit 308, an input device 310 and the database 220. The one or more processors 302, hereinafter referred to as the processor 302 may be implemented as one or more microprocessors, microcomputers, microcontrollers, digital signal processors, central processing units, state machines, logic circuitries, single board computers, and/or any devices that manipulate signals based on operational instructions. As per the illustrated embodiment, the system 104 includes one processor 302. However, it is to be noted that the system 104 include multiple processors as per the requirement and without deviating from the scope of the present disclosure. Among other capabilities, the processor 302 is configured to fetch and execute computer-readable instructions stored in the memory 304.
[0046] The memory 304 is configured to store one or more computer-readable instructions or routines in a non-transitory computer-readable storage medium, which may be fetched and executed to create or share data packets over a network service. The memory 304 may include any non-transitory storage device including, for example, volatile memory such as RAM, or non-volatile memory such as EPROM, flash memory, and the like. In an embodiment, the user interface 306 includes a variety of interfaces, for example, interfaces for data input and output devices, referred to as input/output devices, storage devices, and the like. The user interface 306 facilitates communication of the system 104. In one embodiment, the user interface 306 provides a communication pathway for one or more components of the system 104.
[0047] The user interface 306 may include functionality similar to at least a portion of functionality implemented by one or more computer system interfaces such as those described herein and/or generally known to one having ordinary skill in the art. The user interface 306 may be rendered on the display unit 308, implemented using LCD display technology, OLED display technology, and/or other types of conventional display technology. The display unit 308 is integrated within the system 104 or connected externally. Further the request may be configured to receive requests, queries, or information from the user by using the input device 310. The input device 310 may include, but not limited to, keyboard, buttons, scroll wheels, cursors, touchscreen sensors, audio command interfaces, magnetic strip reader, optical scanner, etc.
[0048] The system 104, may further comprise the database 220. The database 220 may be communicably connected to the processor 302, and the memory 304. The database 220 is configured to store and retrieve the data of the UE 105.
[0049] Further, the processor 302, in an embodiment, may be implemented as a combination of hardware and programming (for example, programmable instructions) to implement one or more functionalities of the processor 302. In the examples described herein, such combinations of hardware and programming may be implemented in several different ways. For example, the programming for the processor 302 may be processor-executable instructions stored on a non-transitory machine-readable storage medium and the hardware for processor 302 may comprise a processing resource (for example, one or more processors), to execute such instructions. In the present examples, the memory 304 may store instructions that, when executed by the processing resource, implement the processor 302. In such examples, the system 104 may comprise the memory 304 storing the instructions and the processing resource to execute the instructions, or the memory 304 may be separate but accessible to the system 104 and the processing resource. In other examples, the processor 302 may be implemented by electronic circuitry.
[0050] In order for the system 104 for distributing data to the plurality of consumer units 101. The processor 302 includes a receiving unit 312, a validation unit 314, a segregation unit 316, and a transmitting unit 318 communicably coupled to each other. In an embodiment, the receiving unit 312, the validation unit 314, the segregation unit 316 and the transmitting unit 318 are enabled by the processor 302 for distributing data into the plurality of consumer units 101.
[0051] The receiving unit 312 of the processor 302 is communicably connected to the UE 105 via the network 102. Accordingly, the receiving unit 312 is configured to receive the request from the User Interface (UI) 201 (shown in FIG. 2) and the request includes one or more policies.
[0052] In an embodiment, the receiving unit 312 is also configured to receive data from the plurality of source units 103. The received data from the plurality of source units 103 includes but not limited to the Short Message Service (SMS), the call, the web page, an email message, the video stream. The data may also include but not limited to an alarm, the counter, the clear code, the FCAPs, the KPI, the probing agent, the CDR and Metric data.
[0053] In an embodiment, the receiving unit 312 is configured to transmit the request from the UI 201 to the validation unit 314. On receipt of the request from the UI 201, the validation unit 314 is configured to validate the one or more policies included in the request from the UI 201. In one embodiment, for example, one or more policies include but not limited to a Quality of Service (QoS) Policies, a routing policies, security policies, an Access Control Policies (ACP), a Traffic Management Policies (TMP), a Resource Allocation Policies (RAP) and so on. In one embodiment, the QoS policy ensure consistent performance in receiving the necessary bandwidth and priority to operate effectively during network congestion. The routing policy determine an optimal path based on cost, latency, or reliability in network congestion. The security policy protects the network from unauthorized access and malicious activity. The ACP restrict access to certain servers or data based on user roles or Internet protocol (IP) addresses. The TMP includes but not limited to bandwidth throttling, traffic shaping, or load balancing policies to optimize network performance. The RAP manage the allocation of network resources.
[0054] Accordingly, the validation unit 314 transmit the validation of the one or more policies to the storage unit (not shown). In one embodiment, the storage unit is configured to store the one or more policies in the database 220 based on the successful validation of the one or more policies. In an exemplary embodiment, the one or more policies included in the request are in a JavaScript Object Notation (JSON) content. The JSON content includes a header that specifies the data of one or more policies. Further, the validation unit 314 (explained in FIG. 3) analyzes the JSON content. Then checks for the header existence by verifying the header key exists in the analyzed JSON content. Accordingly, the validation unit 314 validates the header values by confirming the header existence and ensures the headers includes valid values. Furthermore, the validation unit 314 successfully validates the headers within the JSON content of the one or more policies. In one embodiment, the validation unit 314 successfully validates one or more policies.
[0055] Furthermore, the validation unit 314 transmit the validated one or more policies to the segregation unit 316. On receipt of the validated one or more policies, the segregation unit 316 segregates the data in real time. The segregating unit 316 is configured to segregate the received data from the source unit 103 based on the one or more policies received from the UI 201. The segregation unit 316 segregates the data relevant to each of the plurality of consumer units 101 based on the specific provisioned policies. Accordingly, the segregation unit 316 transmit the segregated data to the transmitting unit 318.
[0056] In one embodiment, for example, segregating the data includes identifying the data associated with each one of the consumer unit 101 as shown in Table 1. The data associated with each one of the consumer unit 101 includes categorizing the data based on one or more policies of the first consumer system 101a, the second consumer system 101b and the third consumer system 101c. Further, categorizing the data includes creating separate databases, file systems, and\or access controls tailored to each one of the consumer unit 101. In an alternate embodiment, the data is segregated based on one or more Artificial Intelligence (AI) or Machine Learning (ML) techniques.
[0057] In one embodiment, the plurality of consumer unit 101 includes but not limited to the Application Programming Interface (API), the API refers to a component or network function sending an API request to retrieve (consume) data for example, the data includes but not limited to the SMS, the call, the web page, an email message, the video stream.
[0058] In an alternate embodiment, the plurality of consumer unit 101 also includes the Network Functions (NF) for example but not limited to Access and Mobility Management Function (AMF), Network Repository Function (NRF), Policy Control Function (PCF), Network Slice Selection Function (NSSF), User Plane Function (UPF) and so on. The data relevant to the context of 5G networks includes but not limited to the Accounting, Performance and Security (FCAPS), Key Performance Indicators (KPIs), probing agent, an alarm, the counter, the clear code, the Fault, Configuration and so on.
[0059] For example, the Table 1a includes the first consumer system 101a, the second consumer system 101b and the third consumer system 101c with the associated data respectively. In one embodiment, the Table 1a may also include multiple consumer system 101.
[0060] Table 1a
Plurality of consumer units Data relevant to the consumer units
First consumer system Short Message Service (SMS), a call, a web page, an email message, a video stream.
Second consumer system an alarm, a counter, a clear code, a Fault, Configuration
Third consumer system Accounting, Performance and Security (FCAPS), Key Performance Indicators (KPIs), probing agent, Call Detail Record (CDR) and Metric data, logs, tracing data.
[0061] For example, the Table 1b includes the specific provisioned policies with the associated data, respectively, for the validation of the one or more policies. In one embodiment, the Table 1b may also include multiple policies.
[0062] Table 1b
Specific provisioned policies (For example) Data associated with the policies
Quality of Service (QoS) policy, routing policy Short Message Service (SMS), a call, a web page, an email message, a video stream.
Security policy or an encryption policy an alarm, a counter, a clear code, a Fault, Configuration
Access Control Policies (ACP), Traffic Management Policies (TMP), Resource Allocation Policies (RAP) Accounting, Performance and Security (FCAPS), Key Performance Indicators (KPIs), probing agent, Call Detail Record (CDR) and Metric data.
[0063] In one embodiment, the system 104 acts as a message broker for distributing data to the plurality of consumer units 101. In this regard, for example, as the system 104 receives the data from the user and the plurality of the source units 103, the system 104 processes the data by validating the one or more polices and segregate the data as per the consumer unit 101 specific policies. Further, the system 104 transmit the segregated data to the relevant consumer unit 101. The distributing data to the plurality of consumer units 101 includes but not limited to the context of a producer-consumer, a publish-subscribe model and the 5G network.
[0064] In one embodiment, the Table 2 includes the segregated data based on the one or more policies associated to the plurality of the consumer unit 101.
[0065] Table 2
Data received from the plurality of source unit Provisioned policies Segregating data according to the consumer unit based on the specific provisioned policies Plurality of consumer units
SMS, the call, the web page, an email message, the video stream, an alarm, the counter, the clear code, the Fault, Configuration, Call Detail Record (CDR), Metric data, Accounting, Performance and Security (FCAPS), Key Performance Indicators (KPIs), probing agent Access Control Policy (ACP), Traffic Management Policy (TCP), Resource Allocation Policy (RAP) Call Detail Record (CDR), Metric data, Accounting, Performance and Security (FCAPS), Key Performance Indicators (KPIs), probing agent Third consumer system
Quality of Service (QoS) policy, routing Policy SMS, the call, the web page, an email message, the video stream First consumer system
security policy/encryption policy an alarm, the counter, the clear code, the fault, configuration Second consumer system
[0066] Further, the segregated data is transmitted to the transmitting unit 318. On receipt of the segregated data from the segregation unit 318, the transmitting unit 318 is configured to transmit the relevant segregated data to the plurality of consumer unit 101 upon the segregation of the data based on the one or more policies. In one embodiment, the plurality of consumer units 101 includes but not limited to at least one of user equipment, the network equipment, an Application programming interface (API) context, the API refers to the component or network function sending the request to retrieve or consume data from the one or more source units 103.
[0067] In alternate embodiment, the network equipment includes the Network Functions (NF) for example but not limited to Access and Mobility Management Function (AMF), the Network Repository Function (NRF), the Policy Control Function (PCF), the Network Slice Selection Function (NSSF), the User Plane Function (UPF) and so on.
[0068] In one embodiment, as explained above the validation unit 314 is configured to validate the one or more policies included in the request received from the UI 201. Further, the validation unit 314 transmit the validated one or more policies to the storage unit to store the one or more policies in the database 220 that eliminates the usage of an additional memory in the database 220.
[0069] In one embodiment, the segregation unit 316 segregates the received data from the source unit 103 based on the one or more policies received from the UI 201. The segregation unit 316 is configured to segregate the data relevant to each of the plurality of consumer units 101 based on the one or more policies in real time and accordingly, the segregated data is not stored in the database 220. Advantageously, by doing this, the system 104 achieves the data optimization and saves the memory space in the database 220 by storing only the validated one or more policies and the data optimization leads to improving the processing efficiency of the system 104.
[0070] Referring to FIG. 4, FIG. 4 illustrates schematic representation of a workflow of the system 104 of FIG. 3, according to various embodiments of the present invention. It is to be noted that the embodiment with respect to FIG. 4 will be explained with respect to the first UE 105a for the purpose of description and illustration and should nowhere be construed as limited to the scope of the present disclosure.
[0071] As mentioned earlier in FIG. 1, each of the first UE 105a and the second UE 105b, may include an external storage device, a bus, a main memory, a read-only memory, a mass storage device, communication port(s), and a processor. The exemplary embodiment as illustrated in the FIG. 4 will be explained with respect to the first UE 101a. The first UE 105a includes one or more primary processors 402 communicably coupled to the one or more processors 302 of the system 104. The one or more primary processors 402 are coupled with a memory unit 404 storing instructions which are executed by the one or more primary processors 402. Execution of the stored instructions by the one or more primary processors 402 enables the first UE 105a to transmit the request including one or more policies to the one or more processors 302. The execution of the stored instructions by the one or more primary processors 402 further enables the first UE 105a to transmit the request including one or more policies to the one or more processors 302.
[0072] In the preferred embodiment, the receiving unit 312 of the processor 302 is communicably connected to the one or more primary processors 402 of the first UE 105a. The receiving unit 312 is configured to receive the request from the UI 201 and the request includes one or more policies.
[0073] As per the illustrated embodiment, the system 104 includes the one or more processors 302, the memory 304, the user interface 306, the display unit 308, the input device 310 and the database 220. The operations and functions of the one or more processors 302, the memory 304, the user interface 306, the display unit 308, the input device 310 and the database 220, are already explained in FIG. 3. For the sake of brevity, a similar description related to the working and operation of the system 104 as illustrated in FIG. 4 has been omitted to avoid repetition.
[0074] Further, the processor 302 includes the receiving unit 312, the validation unit 314, the segregation unit 316 and the transmitting unit 318. The operations and functions of the receiving unit 312, the validation unit 314, the segregation unit 316 and the transmitting unit 318 are already explained in FIG. 3. Hence, for the sake of brevity, it is to be noted that a similar description related to the working and operation of the system 104 as illustrated in FIG. 4 has been omitted to avoid repetition. The limited description provided for the system 104 in FIG. 4, should be read with the description as provided for the system 104 in the FIG. 3 above, and should not be construed as limiting the scope of the present disclosure.
[0075] Referring to FIG. 5, FIG. 5 is a signal flow diagram for distributing data to the plurality of consumer units 101, according to various embodiments of the present invention. For the purpose of description, the signal flow diagram is described with the embodiments as illustrated in FIG. 2 and should nowhere be construed as limiting the scope of the present disclosure.
[0076] At step 502, the receiving unit 312 receives the request from the user and also receive the data from the plurality of source units 103. In one embodiment, the data received from the plurality of source units 103 includes, but not limited to the Short Message Service (SMS), the call, the web page, an email message, the video stream. The data also includes but not limited to an alarm, the counter, the clear code, the FCAPs, the KPI, the probing agent, the CDR and the metric data, logs, tracing data etc. In one embodiment, the request from the user includes one or more policies, the one or more policies includes but not limited to the Quality of Service (QoS) policy, the routing policy, the security policy, an Access Control Policies (ACP), the Traffic Management Policies (TMP), the Resource Allocation Policies (RAP) and so on. Further, one or more policies are transmitted to the validation unit 314.
[0077] At step 504, one or more policies are validated by the validation unit 314 and are stored in the storage unit. In one embodiment, for example, one or more policies are related to the video call data. The validation unit 314 ensures to validate the video call data with the associated policies such as QoS policy and the routing policy. In one embodiment, one or more policies included in the request are in the JSON content. The JSON content includes the header that specifies the data of one or more policies. Further, the validation unit 314 analyzes the JSON content. Then checks for the header existence by verifying the header key exists in the analyzed JSON content. Accordingly, the validation unit 314 validates the header values by confirming the header existence and ensures the headers includes valid values. Furthermore, the validation unit 314 successfully validates the headers within the JSON content of the one or more policies. In one embodiment, the validation unit 314 successfully validates one or more policies.
[0078] Further, the validation of the one or more policies are stored in the database 220. Furthermore, the validation of the one or more policies are transmitted to the segregating unit 316.
[0079] At step 506, the segregation unit 316 segregates the data received from the validation unit 314. The segregation is configured to segregate the data in real time. In one embodiment, the data is segregated based on one or more Artificial Intelligence (AI) or Machine Learning (ML) techniques. Accordingly, based on the validated one or more policies, the data relevant to each of the plurality of consumer system 101 is segregated. Further, the segregated data is transmitted to the relevant consumer unit 101 based on the validation of the one or more policies. In one embodiment, the plurality of consumer unit 101 includes but not limited the UE, the network equipment and the Application Programming Interface (API). The API refers to the component or network function sending an request to retrieve or consume the data, for example, the data includes but not limited to the SMS, the call, the web page, an email message, the video stream.
[0080] In an alternate embodiment, the plurality of consumer unit 101 also includes the Network Functions (NF), for example but not limited to Access and Mobility Management Function (AMF), Network Repository Function (NRF), Policy Control Function (PCF), Network Slice Selection Function (NSSF), User Plane Function (UPF) and so on.
[0081] Referring to FIG. 6, FIG. 6 shows a flow diagram of the method 600 for distributing data to the plurality of consumer units 101. The method 600 is adapted for distributing data to the plurality of consumer units 101. For the purpose of description, the method 600 is described with the embodiments as illustrated in FIG. 3 and should nowhere be construed as limiting the scope of the present disclosure.
[0082] At step 601, the method 600 includes the step of receiving the request from the UI 201 by the receiving unit 312. The received request includes one or more policies. In one embodiment, the receiving unit 312 is also configured in receiving the data from the plurality of source units 103. In one embodiment, the data includes, but not limited to the SMS, the call, the web page, an email message, the video stream and the data includes but not limited to an alarm, a counter, the clear code, FCAPs KPI, probing agent, CDR and Metric data. In one embodiment, the plurality of source units 103 includes but not limited to one of, the node, the server 106, a router. Further, the receiving unit 312 transmit the received data to the validation unit 314.
[0083] At step 602, the method 600 includes the step of validation of the one or more policies included in the request received from the UI 201.
[0084] Accordingly, the validated one or more policies are stored in the database 220 on the successful validation of the one or more policies. After validation, the data received from the source unit 103 is transmitted to the segregation unit 316. In one embodiment, one or more policies includes but not limited to the Quality of Service (QoS) policy, the routing policy, the security policy, an Access Control Policies (ACP), the Traffic Management Policies (TMP), the Resource Allocation Policies (RAP) and so on.
[0085] At step 603, the method 600 includes the step of segregating the received data from the source unit 103 based on the one or more policies received from the UI 201 by the segregation unit 316. The segregation of the data is performed in real time. In one embodiment, based on the one or more policies, the data relevant to each of the plurality of consumer units 101 is segregated. Further, the segregated data is transmitted to the transmitting unit 318.
[0086] At step 604, the method 600 includes the step of transmitting the segregated data relevant consumer unit from the plurality of consumer units 101 upon the segregation of the data based on the one or more policies. In one embodiment, the plurality of consumer system 101 includes the first consumer system 101a, the second consumer system 101b and the third consumer system 101c. The consumer unit 101 includes but not limited to at least one of, the user equipment, the network equipment, Application programming interface (API). The API refers to the component or network function sending an request to retrieve or consume data from the source units 103. In an alternate embodiment, the network equipment includes a Network Functions (NF) for example but not limited to Access and Mobility Management Function (AMF), Network Repository Function (NRF), Policy Control Function (PCF), Network Slice Selection Function (NSSF), User Plane Function (UPF) and so on.
[0087] The present invention further discloses a non-transitory computer-readable medium having stored thereon computer-readable instructions. The computer-readable instructions are executed by a processor 302. The processor 302 is configured to receive a request from a User Interface (UI) 201, the request includes one or more policies. The processor 302 is further configured to receive data from at least one source unit of the plurality of source units 103. The processor 302 is configured to segregate the received data from the at least one source unit 103 based on the one or more policies received from the UI 201. The processor 302 is further configured to transmit the segregated data to the relevant consumer unit of the plurality of consumer units 101 upon the segregation of the data based on the one or more policies.
[0088] A person of ordinary skill in the art will readily ascertain that the illustrated embodiments and steps in description and drawings (FIG.1-6) are set out to explain the exemplary embodiments shown, and it should be anticipated that ongoing technological development will change the manner in which particular functions are performed. These examples are presented herein for purposes of illustration, and not limitation. Further, the boundaries of the functional building blocks have been arbitrarily defined herein for the convenience of the description. Alternative boundaries can be defined so long as the specified functions and relationships thereof are appropriately performed. Alternatives (including equivalents, extensions, variations, deviations, etc., of those described herein) will be apparent to persons skilled in the relevant art(s) based on the teachings contained herein. Such alternatives fall within the scope and spirit of the disclosed embodiments.
[0089] The present disclosure incorporates technical advancement for distributing data to at least one of a plurality of consumer units. The invention takes advantage of enriching data fields at a message broker level and segregating data fields of data feed into multiple feeds based on a consuming system. The method disclosed in the present invention requires no code level changes. All the configurations/policies related to consumer systems may be done on the fly with the help of a User Interface (UI). The present invention also may be configured to reduce hardware infrastructure by avoiding storing incoming data in the database. The system requires no downtime to onboard a new consumer system. The present invention may be performed at an application level or micro-service level.
[0090] The present invention offers multiple advantages over the prior art and the above listed are a few examples to emphasize on some of the advantageous features. The listed advantages are to be read in a non-limiting manner.

REFERENCE NUMERALS
[0091] Environment - 100
[0092] Consumer unit - 101
[0093] Network - 102
[0094] Source unit -103
[0095] System - 104
[0096] User Equipment - 105
[0097] Server - 106
[0098] User Interface - 201
[0099] Processor - 202
[00100] Database - 220
[00101] Processor - 302
[00102] Memory - 304
[00103] User interface - 306
[00104] Display unit - 308
[00105] Input device - 310
[00106] Receiving unit - 312
[00107] Validation unit - 314
[00108] Segregating unit - 316
[00109] Transmitting unit - 318
[00110] Primary processor - 402
[00111] Memory unit - 404

,CLAIMS:CLAIMS
We Claim:
1. A method (600) for distributing data to at least one of a plurality of consumer units (101), the method (600) comprising the steps of:
receiving, by one or more processors (302), a request from a User Interface (UI) (201), the request includes one or more policies;
receiving, by the one or more processors (302), data from at least one source unit of a plurality of source units (103);
segregating, by the one or more processors (302), the received data from the at least one source unit (103) based on the one or more policies received from the UI (201); and
transmitting, by the one or more processors (302), the segregated data to a relevant consumer unit from the plurality of consumer units (101) upon the segregation of the data based on the one or more policies.

2. The method (600) as claimed in claim 1, wherein the method (600) further comprises,
validating, by the one or more processors (302), the one or more policies included in the request received from the UI (201); and
storing, by the one or more processors (302), the one or more policies in a database (220) on the successful validation of the one or more policies.

3. The method (600) as claimed in claim 1, wherein the segregation of the data is performed in real time by the one or more processors (302).

4. The method (600) as claimed in claim 1, wherein based on the one or more policies, the data relevant to each of the plurality of consumer units (101) is segregated.

5. The method (600) as claimed in claim 1, wherein the plurality of source units (103) is at least one of, a node, a server (106), and a router.
6. The method (600) as claimed in claim 1, wherein the plurality of consumer units (103) is at least one of, a User Equipment (UE), and a network equipment.

7. The method (600) as claimed in claim 1, wherein the data includes, but not limited to a Short Message Service (SMS), a call, a web page, an email message, a video stream.

8. A system (104) for distributing data to a plurality of consumer units (103), the system (104) comprising:
a receiving unit (312) configured to:
receive, a request from a User Interface (UI) (201), the request includes one or more policies; and
receive, data from at least one source unit of a plurality of source units (103);
a segregating unit (316) configured to segregate, the received data from the at least one source unit (103) based on the one or more policies received from the UI (201); and
a transmitting unit (318) configured to transmit the segregated data to a relevant consumer unit of the plurality of consumer units (101) upon the segregation of the data based on the one or more policies.

9. The system (104) as claimed in claim 8, wherein the system (104) comprises:
a validation unit (314) configured to validate, the one or more policies included in the request received from the UI (201); and
a storage unit configured to store, the one or more policies upon in a database (220) based on the validation of the one or more policies.

10. The system (104) as claimed in claim 8, wherein the segregation unit (316) is configured to segregate the data in real time.

11. The system (104) as claimed in claim 8, wherein based on the one or more policies, the data relevant to each of the plurality of consumer units (101) is segregated.

12. The system (104) as claimed in claim 8, wherein the plurality of source units (103) is at least one of, a node, a server (106), a router.

13. The system (104) as claimed in claim 8, wherein the plurality of consumer units (101) is at least one of, a User Equipment, a network equipment.

14. The system (104) as claimed in claim 8, wherein the data includes, but not limited to a Short Message Service (SMS), a call, a web page, an email message, a video stream.

15. A User Equipment (UE) (105), comprising:
one or more primary processors (402) communicatively coupled to one or more processors (302), the one or more primary processors (402) coupled with a memory (404), wherein said memory (404) stores instructions which when executed by the one or more primary processors (402) causes the consumer unit (101) to:
transmit, a request including one or more policies to the one or more processors (302);
wherein the one or more processors (302) is configured to perform the steps as claimed in claim 1.