NETWORK-BASED DYNAMIC DATA MANAGEMENT

• US 20130151563A1
• Filed: 12/07/2011
• Published: 06/13/2013
• Est. Priority Date: 12/07/2011
• Status: Active Grant

• Current Assignee: Cisco Technology, Inc. (Cisco Systems, Inc.)
• Original Assignee: Cisco Technology, Inc. (Cisco Systems, Inc.)
• Inventors: Addepalli, Sateesh K., Sudhaakar, Raghuram S., Vasseur, Jean-Philippe, Bonomi, Flavio
• Granted Patent: US 9,462,040 B2
• Time in Patent Office: Days
• US Class Current: 707/792
• CPC Class Codes: G06F 16/2477 Temporal data queries
• CPC Class Codes: G06F 16/787 using geographical or spatial information, e.g. location
• CPC Class Codes: H04L 65/1073 Registration or de-registration
• CPC Class Codes: H04L 67/10 in which an application is distributed across nodes in the network software deployment G06F8/60; multiprogramming arrangements G06F9/46
• CPC Class Codes: H04L 67/52 specially adapted for the location of the user terminal

Abstract

In one embodiment, a router operating in a hierarchically routed computer network may receive collected data from one or more hierarchically lower devices in the network (e.g., hierarchically lower sensors or routers). The collected data may then be converted to aggregated metadata according to a dynamic schema, and the aggregated metadata is stored at the router. The aggregated metadata may also be transmitted to one or more hierarchically higher routers in the network. Queries may then be served by the router based on the aggregated metadata, accordingly.

Claims

1. A method, comprising:

operating a router in a hierarchically routed computer network;

receiving collected data at the router from one or more hierarchically lower devices in the network;

converting the collected data to aggregated metadata according to a dynamic schema;

storing the aggregated metadata at the router;

transmitting the aggregated metadata to one or more hierarchically higher routers in the network; and

serving one or more queries by the router based on the aggregated metadata.

2. The method as in claim 1, wherein the collected data is hierarchically lower aggregated metadata from one or more hierarchically lower routers in the network.

3. The method as in claim 2, wherein converting comprises:

applying a data reduction technique on the collected data, the data reduction technique selected from a group consisting of;

statistical models, regression models, fusion models, Complex Event processing (CEP) models, and statistical filters.

4. The method as in claim 1, wherein the collected data is hierarchically lower raw sensor data from one or more hierarchically lower sensors in the network.

5. The method as in claim 1, further comprising:

determining the dynamic schema based on receiving a new collected data type at the router.

6. The method as in claim 1, further comprising:

determining the dynamic schema based on receiving a new query type at the router.

7. The method as in claim 1, wherein the dynamic schema is time-limited.

8. The method as in claim 1, further comprising:

determining that the dynamic schema does not define a conversion for particular collected data; and

, in response,

storing the particular collected data as raw data.

9. The method as in claim 8, further comprising:

transmitting the raw data to one or more hierarchically higher routers in the network; and

receiving an updated dynamic schema in response to the raw data.

10. The method as in claim 1, further comprising:

detecting a particular behavior based on the collected data;

in response, updating the dynamic schema for hierarchically lower routers based on the detected behavior; and

transmitting the updated dynamic schema to the hierarchically lower routers.

11. The method as in claim 1, further comprising:

receiving a registration request from a plurality of hierarchically lower sensors; and

activating a subset of the hierarchically lower sensors.

12. The method as in claim 11, further comprising:

determining which hierarchically lower sensors to activate based on specific capability of the sensors.

13. The method as in claim 10, further comprising:

determining which hierarchically lower sensors to activate in order to limit a number of active sensors.

14. The method as in claim 1, further comprising:

providing an interface into the router, the interface configured to receive user-defined queries and user-defined schema.

15. An apparatus, comprising:

one or more network interfaces to communicate within a hierarchically routed computer network;

a processor coupled to the network interfaces and adapted to execute one or more processes; and

a memory configured to store a process executable by the processor, the process when executed operable to;

receive collected data from one or more hierarchically lower devices in the network;

convert the collected data to aggregated metadata according to a dynamic schema;

store the aggregated metadata;

transmit the aggregated metadata to one or more hierarchically higher routers in the network; and

serve one or more queries based on the aggregated metadata.

16. The apparatus as in claim 15, wherein the collected data is one of either hierarchically lower aggregated metadata from one or more hierarchically lower routers in the network or hierarchically lower raw sensor data from one or more hierarchically lower sensors in the network.

17. The apparatus as in claim 15, wherein the process when executed is further operable to:

determine the dynamic schema based on receiving a new collected data type.

18. The apparatus as in claim 15, wherein the process when executed is further operable to:

determine the dynamic schema based on receiving a new query type.

19. The apparatus as in claim 15, wherein the process when executed is further operable to:

determine that the dynamic schema does not define a conversion for particular collected data; and

, in response, store the particular collected data as raw data.

20. The apparatus as in claim 19, wherein the process when executed is further operable to:

transmit the raw data to one or more hierarchically higher routers in the network; and

receive an updated dynamic schema in response to the raw data.

21. The apparatus as in claim 15, wherein the process when executed is further operable to:

detect a particular behavior based on the collected data;

in response, update the dynamic schema for hierarchically lower routers based on the detected behavior; and

transmit the updated dynamic schema to the hierarchically lower routers.

22. The apparatus as in claim 15, wherein the process when executed is further operable to:

receive a registration request from a plurality of hierarchically lower sensors; and

activate a subset of the hierarchically lower sensors.

23. A tangible, non-transitory, computer-readable media having software encoded thereon, the software when executed by a processor operable to:

operate a router in a hierarchically routed computer network;

receive collected data at the router from one or more hierarchically lower devices in the network;

convert the collected data to aggregated metadata according to a dynamic schema;

store the aggregated metadata at the router;

transmit the aggregated metadata to one or more hierarchically higher routers in the network; and

serve one or more queries by the router based on the aggregated metadata.

24. A method, comprising:

determining a particular location of a data generating device in a computer network;

registering the device along with the data to be generated and the particular location to a hierarchically higher registration device;

receiving a response from the registration device; and

determining whether to activate data generation at the data generating device based on the response.

25. The method as in claim 24, wherein the response indicates a number N of devices that should be activated in the particular location, the method further comprising:

transmitting an offering message from the data generating device within the particular location indicating the data to be generated;

receiving a number M of replies from other data generating devices within the particular location that are reporting the same data to be generated; and

activating data generation for the data to be generated by the data generating device in response to M being less than N.