Embedded event processing

• US 9,712,645 B2
• Filed: 01/30/2015
• Issued: 07/18/2017
• Est. Priority Date: 06/26/2014
• Status: Active Grant

• Current Assignee: Oracle International Corporation (Oracle Corporation)
• Original Assignee: Oracle International Corporation (Oracle Corporation)
• Inventors: de Castro Alves, Alexandre, Kumar, Prabish, Gatty, Yathish, Mahendru, Ashish
• Primary Examiner(s): Nguyen, Tammy
• Application Number:
  US14/610,971
• Publication Number:
  US 20150381712A1
• Time in Patent Office: 900 Days
• Field of Search: 709205, 709210, 709213, 345411, 310316
• CPC Class Codes: G06F 16/24568 Data stream processing; Continuous queries
• CPC Class Codes: H04L 67/303 Terminal profiles
• CPC Class Codes: H04L 67/34 involving the movement of software or configuration parameters network booting or remote initial program loading [RIPL] G06F9/4416
• CPC Class Codes: H04L 67/55 Push-based network services

Abstract

Techniques for embedded event processing are provided. In some examples, instructions for executing at least a subset of complex event processing features may be received. A stream of events received by the edge computing device may be identified. Additionally, the events of the stream utilizing the subset of complex event processing features may be processed. Further, in some aspects, the processed events may be provided to a complex event platform of a server.

Claims

1. A system, comprising:

a memory storing computer-executable instructions; and

a processor configured to access the memory and execute the computer-executable instructions to at least;

manage a plurality of different feature sets for implementing different implementation versions of a complex event processing platform, at least a first subset of the plurality of different feature sets for implementing a first implementation version of the different implementation versions and at least a second subset of the plurality of different feature sets for implementing a second implementation version of the different implementation versions;

receive device capability information from a plurality of edge devices;

determine a device profile for each of the plurality of edge devices based at least in part on the device capability information of each of the respective plurality of edge devices;

generate at least the first implementation version or the second implementation version of the different implementation versions of the complex event processing platform for at least a first determined device profile;

provide the first implementation version of the complex event processing platform to a first device of the plurality of edge devices according to the determined device profile of the first device; and

receive events from the first implementation version of the complex event processing platform executed by the first device.

2. The system of claim 1, wherein the plurality of edge devices comprise at least one of a handheld device, a desktop device, a laptop device, an embedded device, an enterprise device, or a client device.

3. The system of claim 1, wherein at least the first implementation version and the second implementation version of the different implementation versions of the complex event processing platform include different subsets of the plurality of different features sets.

4. The system of claim 1, wherein the first implementation version of the complex event processing platform is provided to the first device, by a device manager, as a set of instructions.

5. The system of claim 4, wherein the set of instructions comprise a bundle order.

6. The system of claim 5, wherein the bundle order identifies at least one of an implementation order or dependencies of the plurality of different feature sets included in the first implementation version of the complex event processing platform provided to the first device.

7. The system of claim 1, wherein the first implementation version of the complex event processing platform enables the first device to implement complex event processing on the events prior to receipt of the events by the system.

8. A computer-implemented method, comprising:

providing, by a processor of an edge computing device, capability information of the edge computing device to a server;

receiving, by the processor of the edge computing device, instructions for executing at least a first subset of complex event processing features, the first subset of complex event processing features corresponding to a first implementation version of a plurality of different implementation versions built based at least in part on the capability information of the edge computing device, the first subset of complex event processing features being different from a second subset of complex event process features of a second implementation version of the plurality of different implementation versions, and the second implementation version configured for a second edge computing device based at least in part on second capability information associated with the second edge computing device;

identifying, by the processor of the edge computing device, a stream of events received by the edge computing device;

processing, by the processor of the edge computing device, the events of the stream utilizing the first subset of complex event processing features; and

providing, by the processor of the edge computing device, the processed events to a complex event platform of the server.

10. The computer-implemented method of claim 8, wherein the processing of the events of the stream is performed based at least in part on local context information identified by the edge computing device.

11. The computer-implemented method of claim 8, wherein the edge computing device comprises at least one of a handheld device, a desktop device, a laptop device, an embedded device, an enterprise device, or a client device.

12. The computer-implemented method of claim 8, wherein the server is configured to determine a profile for the edge computing device based at least in part on the capability information of the edge computing device.

13. The computer-implemented method of claim 12, further the capability information is provided to the server at least prior to receiving the instructions for executing the first subset of complex event processing features.

9. The computer-implemented method of 8, wherein the instructions for executing the first subset of the complex event processing features are received from the server.

14. A non-transitory computer-readable storage medium configured to store computer-executable instructions that, when executed by a computer system, cause the computer system to perform operations comprising:

managing a plurality of different feature sets for implementing different implementation versions of a complex event processing platform, at least a first subset of the plurality of different feature sets for implementing a first implementation version of the different implementation versions and at least a second subset of the plurality of different feature sets for implementing a second implementation version of the different implementation versions;

receiving capability information for a plurality of edge computing devices;

determining a profile for each of the plurality of edge computing devices based at least in part on the capability information of each respective edge device of the plurality of edge computing devices;

generating the first implementation version of the complex event processing platform with limited functionality for the determined profile;

providing the version of the complex event processing platform with limited functionality to the edge computing device for execution; and

enabling the edge computing device to execute the version of the complex event processing platform with limited functionality for processing events received at the edge computing device.

15. The non-transitory computer-readable storage of claim 14, wherein the operations further comprise receiving processed events from the version of the complex event processing platform with limited functionality executed by the edge computing device.

16. The non-transitory computer-readable storage of claim 15, wherein the version of the complex event processing platform with limited functionality enables the edge computing device to implement complex event processing on the events prior to receipt of the events by the computer system.

17. The non-transitory computer-readable storage of claim 14, wherein the version of the complex event processing platform with limited functionality is provided to the edge computing device as a bundle order of instructions.

18. The non-transitory computer-readable storage of claim 17, wherein the bundle order identifies at least one of an implementation order or dependencies of the plurality of different feature sets included in the version of the complex event processing platform with limited functionality provided to the edge computing device.