EVENT PROCESSING

• US 20180287969A1
• Filed: 03/28/2017
• Published: 10/04/2018
• Est. Priority Date: 03/28/2017
• Status: Active Grant

• Current Assignee: International Business Machines Corporation
• Original Assignee: International Business Machines Corporation
• Inventors: BROADHURST, Peter A., HOSIE, John, NICHOLSON, Robert B., PHIPPEN, Robert W., ZHANG, Jianjun
• Granted Patent: US 10,666,713 B2
• Time in Patent Office: Days
• CPC Class Codes: H04L 51/214 using selective forwarding
• 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/55 Push-based network services

Abstract

A facility for processing an event of a distributed processing environment is provided. The facility includes separating a plurality of processing flows into a plurality of flow groups, each flow group having a respective identifier. The identifier of each flow group is then associated with a respective topic. Based on the occurrence of an event, a message having a topic based on the event is published along with the identifier of the flow group associated with the topic. A processing flow of the flow group having the identifier of the message may then be used to process the event.

Claims

1. A computer-implemented method for processing an event of a distributed processing environment, the distributed processing environment comprising a flow engine adapted to implement a plurality of processing flows, the method comprising:

separating the plurality of processing flows into a plurality of flow groups, each flow group having a respective identifier;

associating the identifier of each flow group with a respective topic;

based on the occurrence of an event in an application or service, publishing a message having a topic based on the event, the message including the identifier of the flow group associated with the topic; and

using a processing flow of the flow group having the identifier of the message to process the event.

2. The method of claim 1, wherein using the processing flow of the flow group having the identifier of the message to process the event comprises:

analyzing the message to determine the identifier included in the message; and

identifying the flow group having the determined identifier.

3. The method of claim 1, wherein using the processing flow of the flow group having the identifier of the message to process the event comprises:

executing a processing flow of the flow group having the identifier of the message, wherein an input to the processing flow is based on at least a portion of message.

4. The method of claim 3, wherein the at least a portion of the message comprises information relating to the event.

5. The method of claim 1, wherein using the processing flow of the flow group having the identifier of the message to process the event comprises:

passing data of the message to a processing flow of the flow group having the identifier of the message.

6. The method of claim 1, wherein associating the identifier of each flow group with a respective topic comprises:

for each flow group, generating a topic based on the identifier of the flow group and registering the generated topic and the flow group with a message system.

7. The method of claim 1, further comprising detecting the occurrence of an event in an application or service by identifying at least one of:

modification of the application or service;

modification of a component or resource;

a change in the status of the application or service; and

a change in a flow of data to and/or from the application or service.

8. The method of claim 1, wherein the processing flow of the flow group comprises a micro-service.

9. A computer program product for processing an event of a distributed processing environment, the distributed processing environment comprising a flow engine adapted to implement a plurality of processing flows, the computer program product comprising:

a computer readable storage medium having program instructions embodied therewith, the program instructions executable by a processing unit to cause the processing unit to perform a method comprising;

separating the plurality of processing flows in a plurality of flow groups, each flow group having a respective identifier;

associating the identifier of each flow group with a respective topic;

based on the occurrence of an event in an application or service, publishing a message having a topic based on the event, the message including the identifier of the flow group associated with the topic; and

using a processing flow of the flow group having the identifier of the message to process the event.

10. The computer program product claim 9, wherein using the processing flow of the flow group having the identifier of the message to process the event comprises:

analyzing the message to determine the identifier included in the message; and

identifying the flow group having the determined identifier.

11. The computer program product of claim 9, wherein using the processing flow of the flow group having the identifier of the message to process the event comprises:

executing a processing flow of the flow group having the identifier of the message, wherein an input to the processing flow is based on at least a portion of message.

12. The computer program product of claim 11, wherein the at least a portion of the message comprises information relating to the event.

13. The computer program product of claim 9, wherein using the processing flow of the flow group having the identifier of the message to process the event comprises:

passing data of the message to a processing flow of the flow group having the identifier of the message.

14. The computer program product of claim 9, wherein associating the identifier of each flow group with a respective topic comprises:

for each flow group, generating a topic based on the identifier of the flow group and registering the generated topic and the flow group with a message system.

15. The computer program product of claim 9, further comprising detecting the occurrence of an event in an application or service by identifying at least one of:

modification of the application or service;

modification of a component or resource;

a change in the status of the application or service; and

a change in a flow of data to and/or from the application or service.

16. A system for processing an event of a distributed processing environment, the distributed processing environment comprising a flow engine adapted to implement a plurality of processing flows, the system comprising:

a memory; and

a processor communicatively coupled to the memory, wherein the system performs a method comprising;

separating the plurality of processing flows into a plurality of flow groups, each flow group having a respective identifier;

associating the identifier of each flow group with a respective topic;

based on the occurrence of an event in an application or service, publishing a message having a topic based on the event, the message including the identifier of the flow group associated with the topic; and

using a processing flow of the flow group having the identifier of the message to process the event.

17. The system of claim 16, wherein using the processing flow of the flow group having the identifier of the message to process the event comprises:

analyzing the message to determine the identifier included in the message; and

identifying the flow group having the determined identifier.

18. The system of claim 16, wherein using the processing flow of the flow group having the identifier of the message to process the event comprises:

executing a processing flow of the flow group having the identifier of the message, wherein an input to the processing flow is based on at least a portion of message.

19. The system of claim 18, wherein the at least a portion of the message comprises information relating to the event.

20. The system of claim 16, wherein using the processing flow of the flow group having the identifier of the message to process the event comprises:

passing data of the message to a processing flow of the flow group having the identifier of the message.