System and method for abstracting and orchestrating mobile data networks in a network environment
A method is provided in one example and includes receiving data from a network element, determining a candidate data processing task for the received data based upon a first similarity metric between the received data and data currently associated with the candidate data processing task, and sending the received data to the candidate data processing task.
1. A method, comprising:
receiving, by a server, data from a network element;
determining, by a data control task having a plurality of candidate data processing tasks associated therewith, a particular candidate data processing task of the plurality of candidate processing tasks for the received data based upon a first similarity metric representative of a measure of similarity between the received data and data currently associated with the particular candidate data processing task, wherein determining the particular candidate data processing task includes determining whether the first similarity metric is within a predetermined threshold; and
sending the received data to the particular candidate data processing task, wherein the particular candidate data processing task is configured to determine whether the received data is suitable for the particular candidate data processing task based upon a second similarity metric between the received data and data currently associated with the particular candidate data processing task, wherein the second similarity metric is representative of a greater level of similarity analysis than the first similarity metric.
2. The method of claim 1 , further comprising receiving an indication regarding whether the candidate data processing task has accepted the received data.
3. The method of claim 2 , further comprising updating similarity information for the candidate data processing task based upon whether the candidate data processing task has accepted the received data.
4. The method of claim 2 , further comprising determining a next candidate data processing task if the candidate data processing task indicates that the data processing task has not accepted the received data.
5. The method of claim 1 , further comprising sending a message indicative of whether the candidate data processing task has accepted the received data based upon whether the received data is suitable for the data processing task.
6. The method of claim 1 , further comprising processing the received data by the candidate data processing task according to at least one predefined rule.
7. Logic encoded in one or more non-transitory tangible media that includes code for execution and when executed by a processor operable to perform operations comprising:
receiving, by a server, data from a network element;
determining, by a data control task having a plurality of candidate data processing tasks associated therewith, a particular candidate data processing task of the plurality of candidate processing tasks for the received data based upon a first similarity metric representative of a measure of similarity between the received data and data currently associated with the particular candidate data processing task, wherein determining the particular candidate data processing task includes determining whether the first similarity metric is within a predetermined threshold; and
sending the received data to the particular candidate data processing task, wherein the particular candidate data processing task is configured to determine whether the received data is suitable for the particular candidate data processing task based upon a second similarity metric between the received data and data currently associated with the particular candidate data processing task, wherein the second similarity metric is representative of a greater level of similarity analysis than the first similarity metric.
8. The media of claim 7 , wherein the operations further comprise receiving an indication regarding whether the candidate data processing task has accepted the received data.
9. The media of claim 8 , wherein the operations further comprise determining a next candidate data processing task if the candidate data processing task indicates that the data processing task has not accepted the received data.
10. The media of claim 8 , wherein the operations further comprise updating similarity information for the candidate data processing task based upon whether the candidate data processing task has accepted the received data.
11. The media of claim 7 , wherein the operations further comprise sending a message indicative of whether the candidate data processing task has accepted the received data based upon whether the received data is suitable for the data processing task.
12. The media of claim 7 , wherein the operations further comprise processing the received data by the candidate data processing task according to at least one predefined rule.
13. An apparatus, comprising:
a memory element configured to store data,
a processor operable to execute instructions associated with the data, and
an abstraction module, the apparatus being configured to:
receive, by a server, data from a network element;
determine, by a data control task having a plurality of candidate data processing tasks associated therewith, a particular candidate data processing task of the plurality of candidate processing tasks for the received data based upon a first similarity metric representative of a measure of similarity between the received data and data currently associated with the particular candidate data processing task, wherein determining the particular candidate data processing task includes determining whether the first similarity metric is within a predetermined threshold; and
send the received data to the particular candidate data processing task, wherein the particular candidate data processing task is configured to determine whether the received data is suitable for the particular candidate data processing task based upon a second similarity metric between the received data and data currently associated with the particular candidate data processing task, wherein the second similarity metric is representative of a greater level of similarity analysis than the first similarity metric.
14. The apparatus of claim 13 , wherein the apparatus is further configured to receive an indication regarding whether the candidate data processing task has accepted the received data.
15. The apparatus of claim 14 , wherein the apparatus is further configured to update similarity information for the candidate data processing task based upon whether the candidate data processing task has accepted the received data.
16. The apparatus of claim 14 , wherein the apparatus is further configured to determine a next candidate data processing task if the candidate data processing task indicates that the data processing task has not accepted the received data.
17. The apparatus of claim 13 , wherein the apparatus is further configured to send a message indicative of whether the candidate data processing task has accepted the received data based upon whether the received data is suitable for the data processing task.