Cloud-edge topologies

Patent metadata

Field	Value
Publication number	US-9876851-B2
Application number	US-201514750031-A
Country	US
Kind code	B2
Filing date	Jun 25, 2015
Priority date	Dec 27, 2011
Publication date	Jan 23, 2018
Grant date	Jan 23, 2018

Abstract

The description relates to cloud-edge topologies. Some aspects relate to cloud-edge applications and resource usage in various cloud-edge topologies. Another aspect of the present cloud-edge topologies can relate to the specification of cloud-edge applications using a temporal language. A further aspect can involve an architecture that runs data stream management systems (DSMSs) engines on the cloud and cloud-edge computers to run query parts.

First claim

The invention claimed is:

1. A system, comprising:
storage storing a Real-time Applications over Cloud-Edge (RACE) cloud-based management service that is executable by a computing device, the RACE cloud-based management service configured to interact with an application executing on cloud-based resources and at individual edge computing devices in communication with the cloud-based resources, the RACE cloud-based management service configured to mimic a data stream management systems (DSMS) engine to receive temporal declarative queries from the individual edge computing devices; and,
a hardware RACE processor configured to intercept the temporal declarative queries and to parse and compile individual temporal declarative queries into an object representation.

2. The system of claim 1 , wherein the hardware RACE processor comprises a graph constructor configured to generate a query pattern from the object representation.

3. The system of claim 2 , wherein, in an instance where the query pattern includes input streams that refer to data streams from each edge computing device, the graph constructor is further configured to create a query graph that includes multiple instances of the query pattern by splitting the data streams into multiple instances of the query pattern with one input stream per edge of the query graph.

4. The system of claim 3 , wherein the hardware RACE processor comprises an optimizer configured to determine where to execute individual operators of the query graph to reduce total communication costs between the edge computing devices and the cloud-based resources.

5. The system of claim 4 , wherein the optimizer is configured to determine where to execute individual operators of the query graph to minimize total communication costs between the edge computing devices and the cloud-based resources.

6. The system of claim 1 , wherein the hardware RACE processor comprises a query constructor configured to generate object representations of types, adapters, and sub-queries to be executed on each edge computing device or at the cloud.

7. The system of claim 1 , manifest as cloud-based servers or manifest on one of the individual edge computing devices.

8. A method implemented by one or more computing devices, comprising:
interacting with an application executing on cloud-based resources and at individual edge computing devices in communication with the cloud-based resources;
intercepting and parsing temporal declarative queries from the individual edge computing devices, the temporal declarative queries being associated with the application; and,
compiling individual temporal declarative queries into an object representation.

9. The method of claim 8 , further comprising generating a query pattern from the object representation.

10. The method of claim 9 , wherein, in an instance where the query pattern includes input streams that refer to data streams from each edge computing device, the method further comprises creating a query graph that includes multiple instances of the query pattern by splitting the data streams into multiple instances of the query pattern with one input stream per edge of the query graph.

11. The method of claim 10 , further comprising determining where to execute individual operators of the query graph to reduce total communication costs between the edge computing devices and the cloud-based resources.

12. The method of claim 8 , further comprising generating object representations of types, adapters, and sub-queries to be executed on each edge computing device or at the cloud-based resources.

13. The method of claim 8 , wherein the one or more computing devices are manifest as cloud-based servers or manifest as at least one of the individual edge computing devices.

14. A system comprising:
a first processing device and a first storage device storing first computer-executable instructions which, when executed by the first processing device, cause the first processing device to:
interact with an application executing on cloud-based resources and at individual edge computing devices in communication with the cloud-based resources, and
receive temporal declarative queries from the individual edge computing devices; and,

a second processing device and a second storage device storing second computer-executable instructions which, when executed by the second processing device, cause the second processing device to:
intercept the temporal declarative queries, and
parse and compile individual temporal declarative queries into an object representation.

15. The system of claim 14 , wherein the second computer-executable instructions further cause the second processing device to generate a query pattern from the object representation.

16. The system of claim 15 , wherein, in an instance where the query pattern includes input streams that refer to data streams from each edge computing device, the second computer-executable instructions further cause the second processing device to create a query graph that includes multiple instances of the query pattern by splitting the data streams into multiple instances of the query pattern with one input stream per edge of the query graph.

17. The system of claim 16 , wherein the second computer-executable instructions further cause the second processing device to determine where to execute individual operators of the query graph to reduce total communication costs between the edge computing devices and the cloud-based resources.

18. The system of claim 17 , wherein the second computer-executable instructions further cause the second processing device to determine where to execute individual operators of the query graph to minimize total communication costs between the edge computing devices and the cloud-based resources.

19. The system of claim 14 , wherein the second computer-executable instructions further cause the second processing device to generate object representations of types, adapters, and sub-queries to be executed on each edge computing device or at the cloud.

20. The system of claim 14 , manifest as cloud-based servers or manifest on at least one of the individual edge computing devices.

Assignees

• Microsoft Technology Licensing Llc

Inventors

• Chandramouli Badrish
• Nath Suman K
• Zhou Wenchao

Classifications

• H04W4/023

  using mutual or relative location information between multiple location based services [LBS] targets or of distance thresholds · CPC title

• G06F16/24568

  Data stream processing; Continuous queries · CPC title

• G06F9/5072

  Grid computing · CPC title

• G06F9/505 Primary

  considering the load · CPC title

• H04L43/045

  for graphical visualisation of monitoring data · CPC title