Network embedded framework for distributed network analytics

1. A method performed at least partly by a network-analytics controller of a network, the method comprising:

instructing, by the network-analytics controller, analytics agents to each perform tasks, individual ones of the analytics agents running on respective network nodes in the network;

receiving, at the network-analytics controller and from the analytics agents, telemetry data associated with execution of the tasks, the telemetry data being generated and at least partially processed by the analytics agents;

identifying unused data from the telemetry data;

adjusting an analytics scope policy associated with the network such that the analytics agents refrain from performing a task of the tasks that result in generation or processing of the unused data; and

using the analytics scope policy, causing the analytics agents to refrain from performing the task that results in the generation or the processing of the unused data.

2. The method of claim 1 , wherein the network-analytics controller comprises:

a monitor operative configured to monitor the network nodes and determine which of the network nodes fall within the analytics scope policy;

a deployment manager configured to assign the tasks to each analytics agent at each network node determined to be within the analytics scope policy; and

an analytics collector to collect the telemetry data from the analytics agents and process the telemetry data according to the analytics scope policy.

3. The method of claim 1 , further comprising;

establishing a node manager that communicates with the network-analytics controller to discover, register, and deploy the tasks assigned to the analytics agents;

establishing a data source handler that configures data sources at each of the network nodes to collect data called for by the analytics agents; and

establishing a network aggregator that preprocesses and forwards the telemetry data to the network-analytics controller.

4. The method of claim 3 , further comprising:

deploying, by the node manager, the tasks assigned to the analytics agents;

configuring, by the data source handler, data sources at the network nodes to collect data called for by the tasks;

collecting, by the data source handler, the data from the data sources; and

forwarding the data to the network nodes.

5. The method of claim 1 , further comprising:

exposing, by a frontend associated with the network-analytics controller, an interface configured to receive input from a user associated with the network; and

receiving, via the interface, user input that at least partially defines the analytics scope policy, the user input defining:

data sources from which data is received for processing during execution of the tasks;

a schedule according to which the tasks are performed; and

the tasks that are to be performed.

6. The method of claim 1 , wherein instructing the analytics agents to each perform the tasks includes:

programming the analytics agents to:

perform the tasks on the respective network nodes;

obtain data from predefined data sources from which the data is obtained for processing during execution of the tasks; and

perform the tasks on the network nodes according to a schedule.

7. The method of claim 1 , wherein:

the network-analytics controller is implemented in a software-defined networking (SDN) framework; and

the tasks are defined using a data model that is distributed to each of the analytics agents.

8. A system that runs a network-analytics controller of a network, the system comprising:

one or more processors; and

one or more non-transitory computer-readable media storing computer-executable instructions that, when executed by the one or more processors, cause the one or more processors to perform operations comprising:

instructing, by the network-analytics controller, analytics agents to each perform tasks, individual ones of the analytics agents running on respective network nodes in the network;

receiving, at the network-analytics controller and from the analytics agents, telemetry data associated with execution of the tasks, the telemetry data being generated and at least partially processed by the analytics agents;

identifying unused data from the telemetry data;

adjusting an analytics scope policy associated with the network such that the analytics agents refrain from performing a task of the tasks that result in generation or processing of the unused data; and

using the analytics scope policy, causing the analytics agents to refrain from performing the task that results in the generation or the processing of the unused data.

9. The system of claim 8 , wherein the network-analytics controller comprises:

a monitor operative configured to monitor the network nodes and determine which of the network nodes fall within the analytics scope policy;

a deployment manager configured to assign the tasks to each analytics agent at each network node determined to be within the analytics scope policy; and

an analytics collector to collect the telemetry data from the analytics agents and process the telemetry data according to the analytics scope policy.

10. The system of claim 8 , the operations further comprising;

establishing a node manager that communicates with the network-analytics controller to discover, register, and deploy the tasks assigned to the analytics agents;

establishing a data source handler that configures data sources at each of the network nodes to collect data called for by the analytics agents; and

establishing a network aggregator that preprocesses and forwards the telemetry data to the network-analytics controller.

11. The system of claim 10 , the operations further comprising:

deploying, by the node manager, the tasks assigned to the analytics agents;

configuring, by the data source handler, data sources at the network nodes to collect data called for by the tasks;

collecting, by the data source handler, the data from the data sources; and

forwarding the data to the network nodes.

12. The system of claim 8 , the operations further comprising:

exposing, by a frontend associated with the network-analytics controller, an interface configured to receive input from a user associated with the network; and

receiving, via the interface, user input that at least partially defines the analytics scope policy, the user input defining:

data sources from which data is received for processing during execution of the tasks;

a schedule according to which the tasks are performed; and

the tasks that are to be performed.

13. The system of claim 8 , wherein instructing the analytics agents to each perform the tasks includes:

programming the analytics agents to:

perform the tasks on the respective network nodes;

obtain data from predefined data sources from which the data is obtained for processing during execution of the tasks; and

perform the tasks on the network nodes according to a schedule.

14. The system of claim 8 , wherein:

the network-analytics controller is implemented in a software-defined networking (SDN) framework; and

the tasks are defined using a data model that is distributed to each of the analytics agents.

15. One or more non-transitory computer-readable media storing computer-executable instructions that, when executed by one or more processors, cause the one or more processors to perform operations comprising:

causing analytics agents to execute on respective network nodes in a network, the network being associated with a network-analytics controller;

programming the analytics agents to:

obtain data from predefined data sources;

perform tasks on the respective network nodes by processing the data to generate telemetry data; and

perform the tasks according to a schedule;

receiving, at the network-analytics controller, from the analytics agents, and according to the schedule, the telemetry data associated with execution of the tasks, the telemetry data being generated and at least partially processed by the analytics agents;

identifying unused data from the telemetry data;

adjusting an analytics scope policy associated with the network such that the analytics agents refrain from performing a task of the tasks that result in generation or processing of the unused data; and

using the analytics scope policy, causing the analytics agents to refrain from performing the task that results in the generation or the processing of the unused data.

16. The one or more non-transitory computer-readable media of claim 15 , wherein the network-analytics controller comprises:

a monitor operative configured to monitor the network nodes and determine which of the network nodes fall within an analytics scope policy associated with the network;

a deployment manager configured to assign the tasks to each analytics agent at each network node determined to be within the analytics scope policy; and

an analytics collector to collect the telemetry data from the analytics agents and process the telemetry data according to the analytics scope policy.

17. The one or more non-transitory computer-readable media of claim 15 , the operations further comprising:

exposing, by a frontend associated with the network-analytics controller, an interface configured to receive input from a user associated with the network; and

receiving, via the interface, user input that at least partially defines:

the data sources from which data is received for processing during execution of the tasks;

the schedule according to which the tasks are performed; and

the tasks that are performed.

18. The one or more non-transitory computer-readable media of claim 15 , the operations further comprising:

establishing a node manager that communicates with the network-analytics controller to discover, register, and deploy the tasks assigned to the analytics agents;

establishing a data source handler that configures data sources at each of the network nodes to collect data called for by the analytics agents; and

establishing a network aggregator that preprocesses and forwards the telemetry data to the network-analytics controller.

19. The one or more non-transitory computer-readable media of claim 18 , the operations further comprising:

discovering, registering, and deploying, by the node manager, the tasks assigned to the analytics agents;

configuring, by the data source handler, the data sources at the network nodes to collect data called for by the tasks; and

collecting, by the data source handler, the data from the data sources.