Monitoring and distributing event processing within a complex event processing environment

• US 9,264,310 B2
• Filed: 04/12/2013
• Issued: 02/16/2016
• Est. Priority Date: 04/12/2013
• Status: Expired due to Fees

• Current Assignee: International Business Machines Corporation
• Original Assignee: International Business Machines Corporation
• Inventors: Granshaw, David, Massey, Samuel T., McGinnes, Daniel J., Ross, Martin A., Schofield, Richard G., Stirling, Craig H.
• Primary Examiner(s): Chan, Wing F
• Assistant Examiner(s): MANIWANG, JOSEPH R
• Application Number:
  US13/861,415
• Publication Number:
  US 20140310331A1
• Time in Patent Office: 1,040 Days
• Field of Search: 709/223, 709/224, 709/226
• US Class Current: 1/1
• CPC Class Codes: G06F 16/24568 Data stream processing; Continuous queries
• CPC Class Codes: G06F 9/5083 Techniques for rebalancing the load in a distributed system
• CPC Class Codes: H04L 41/0893 Assignment of logical groups to network elements
• CPC Class Codes: H04L 43/0817 by checking functioning
• CPC Class Codes: H04L 43/16 Threshold monitoring
• CPC Class Codes: H04L 67/61 taking into account QoS or priority requirements

Abstract

A method for event processing within a complex event processing environment. The method includes monitoring a plurality of event processing paths of the complex event processing environment. The method includes determining that utilization of server resources in the complex event processing environment has exceeded a threshold value and identifying one or more event processing paths responsible for the high utilization of server resources. The method includes determining that the one or more event processing paths contain an independent rule, wherein an independent rule includes a rule or a rule subset where data for processing of the rule or rule subset is accessible by a client computing device. The method then includes determining the client computing device can perform processing of the independent rule and transferring processing of the independent rule to the client computing device.

Claims

1. A method for event processing within a complex event processing environment, the method comprising:

monitoring a plurality of event processing paths, wherein an event processing path is a path of communication between a client computing device and a server computing device within a complex event processing environment;

determining, by one or more computer processors, that utilization of server resources in the complex event processing environment has exceeded a threshold value;

identifying an event processing path of the plurality of event processing paths and a corresponding client computing device that is responsible for the high utilization of server resources;

determining, by the one or more computer processors, that the identified event processing path contains an independent rule, wherein the independent rule includes a rule or a rule subset where all data required for processing the independent rule on the identified event processing path is supplied by the identified corresponding client computing device that is responsible for the high utilization of server resources;

determining, by the one or more computer processors, the identified corresponding client computing device can perform processing of the independent rule; and

transferring processing of the independent rule to the identified corresponding client computing device.

2. The method of claim 1, wherein the threshold value for utilization of server resources is set by an owner or operator of the server computing device.

3. The method of claim 1, wherein the communication includes one or more of:

contextual data, temporal data, rule statements, available resources and resource requirements.

4. The method of claim 3, wherein the client computing device includes multiple computing devices connected to the complex event processing environment through one or more of:

a local area network, a wide area network or a combination of a local area network and a wide area network.

5. The method of claim 1, further comprising:

determining, by the one or more computer processors, that the identified event processing path contains rules where data required for processing the rules on the identified event processing path is not supplied by the identified corresponding client computing device;

splitting the rules into rule subsets, wherein at least one of the rule subsets is an independent rule; and

transferring processing of the rule subset that includes an independent rule to the identified corresponding client computing device.

6. The method of claim 1, wherein the determination that the identified corresponding client computing device can perform processing further comprises determining, by the one or more computer processors, the identified corresponding client computing device has resources capable of processing the independent rule and is willing to accept processing of the rule.

7. The method of claim 1, wherein a rule for rule processing includes a data to be analyzed and an action to be taken based on the analyzed data.

8. A computer program product for event processing within a complex event processing environment, the computer program product comprising:

one or more computer-readable tangible storage devices and program instructions stored on the one or more computer-readable tangible storage devices, the program instructions comprising;

program instructions to monitor a plurality of event processing paths, wherein an event processing path is a path of communication between a client computing device and a server computing device within a complex event processing environment;

program instructions to determine that utilization of server resources in the complex event processing environment has exceeded a threshold value;

program instructions to identify an event processing path of the plurality of event processing paths and a corresponding client computing device that is responsible for the high utilization of server resources;

program instructions to determine that the identified event processing path contains an independent rule, wherein the independent rule includes a rule or a rule subset where all data required for processing the independent rule on the identified event processing path is supplied by the identified corresponding client computing device that is responsible for the high utilization of server resources;

program instructions to determine the identified corresponding client computing device can perform processing of the independent rule; and

program instructions to transfer processing of the independent rule to the identified corresponding client computing device.

9. The computer program product of claim 8, wherein the threshold value for utilization of server resources is set by an owner or operator of the server computing device.

10. The computer program product of claim 8, wherein the communication includes one or more of:

contextual data, temporal data, rule statements, available resources and resource requirements.

11. The computer program product of claim 8, further comprising:

program instructions to determine that the identified event processing path contains rules where data required for processing the rules on the identified event processing path is not supplied by the identified corresponding client computing device;

program instructions to split the rules into rule subsets, wherein at least one of the rule subsets is an independent rule; and

program instructions to transfer processing of the rule subset that includes an independent rule to the identified corresponding client computing device.

12. The computer program product of claim 8, wherein the program instructions to determine that the identified corresponding client computing device can perform processing further comprise program instructions to determine the identified corresponding client computing device has resources capable of processing the independent rule and is willing to accept processing of the rule.

13. A computer system for event processing within a complex event processing environment, the computer system comprising:

one or more computer processors;

one or more computer-readable tangible storage media;

program instructions stored on the one or more computer-readable tangible storage media for execution by at least one of the one or more computer processors, the program instructions comprising;

program instructions to monitor a plurality of event processing paths, wherein an event processing path is a path of communication between a client computing device and a server computing device within a complex event processing environment;

program instructions to determine that utilization of server resources in the complex event processing environment has exceeded a threshold value;

program instructions to identify an event processing path of the plurality of event processing paths and a corresponding client computing device that is responsible for the high utilization of server resources;

program instructions to determine that the identified event processing path contains an independent rule, wherein the independent rule includes a rule or a rule subset where all data required for processing the independent rule on the identified event processing path is supplied by the identified corresponding client computing device that is responsible for the high utilization of server resources;

program instructions to determine the identified corresponding client computing device can perform processing of the independent rule; and

program instructions to transfer processing of the independent rule to the identified corresponding client computing device.

14. The computer system of claim 13, wherein the threshold value for utilization of server resources is set by an owner or operator of the server computing device.

15. The computer system of claim 13, wherein the communication includes one or more of:

contextual data, temporal data, rule statements, available resources and resource requirements.

16. The computer system of claim 15, wherein the client computing device includes multiple computing devices connected to the complex event processing environment through one or more of:

a local area network, a wide area network or a combination of a local area network and a wide area network.

17. The computer system of claim 13, further comprising:

program instructions to determine that the identified event processing path contains rules where data required for processing the rules on the identified event processing path is not supplied by the identified corresponding client computing device;

program instructions to split the rules into rule subsets, wherein at least one of the rule subsets is an independent rule; and

program instructions to transfer processing of the rule subset that includes an independent rule to the identified corresponding client computing device.

18. The computer system of claim 13, wherein the program instructions to determine that the identified corresponding client computing device can perform processing further comprise program instructions to determine the identified corresponding client computing device has resources capable of processing the independent rule and is willing to accept processing of the rule.