Event handling in distributed event handling systems

Patent metadata

Field	Value
Publication number	US-12073265-B2
Application number	US-202217838588-A
Country	US
Kind code	B2
Filing date	Jun 13, 2022
Priority date	Jul 10, 2017
Publication date	Aug 27, 2024
Grant date	Aug 27, 2024

Abstract

The present disclosure generally discloses an event handling capability configured to support handling of events. The event handling capability may be configured to support handling of events in a distributed event handling system, which may use distributed queuing of events, distributed processing of events, and so forth. The distributed event handling system may be serverless cloud system or other type of distributed event handling system. The event handling capability may be configured to support handling of events in a distributed event handling system based on use of a message bus for queuing of events and based on use of hosts for queuing and processing of events.

First claim

What is claimed is:

1. An apparatus, comprising:
at least one processor; and
at least one memory storing instructions which, when executed by the at least one processor, cause the apparatus to:
maintain, by a message bus for a set of nodes, a set of event queues for an event type;
determine, by the message bus based on monitoring of the event queues, event queue status information including respective sets of queue status information associated with the respective event queues;
control, by the message bus based on the event queue status information, storage of a set of events of the event type in the set of event queues;
modify, by the message bus based on an indication of a scaling of the set of nodes for the event type based on the event queue status information, a mapping of respective subsets of the event queues to respective ones of the nodes; and
send, by the message bus toward the set of nodes based on the mapping, the set of events of the event type.

2. The apparatus of claim 1 , wherein the instructions, when executed by the at least one processor, cause the apparatus to:
instantiate the event queues for the event type based on respective requests to subscribe to the message bus for the event type.

3. The apparatus of claim 1 , wherein, for at least one of the event queues, the respective set of queue status information for the respective event queue comprises at least one of a queue length of the respective event queue, an event arrival rate of the respective event queue, or an event departure rate of the respective event queue.

4. The apparatus of claim 1 , wherein the instructions, when executed by the at least one processor, cause the apparatus to:
compute, for each of the event queues in the set of event queues based on the respective sets of queue status information associated with the respective event queues, a respective queue score for the respective event queue.

5. The apparatus of claim 4 , wherein the respective queue scores for the respective event queues are configured such that a longer one of the event queues is selected over a shorter one of the event queues, for storing events of the event type, based on an indication that a length of the longer one of the event queues and a length of the shorter one of the event queues are changing at different rates.

6. The apparatus of claim 4 , wherein, for at least one of the event queues, the respective queue score of the respective event queue is based on an exponentially weighted moving average of a queue length of the respective event queue and an exponentially weighted moving average of a departure rate of the respective event queue.

7. The apparatus of claim 1 , wherein the instructions, when executed by the at least one processor, cause the apparatus to:
provide, by the message bus toward a function manager configured to support the scaling of the set of nodes for the event type, the event queue status information.

8. The apparatus of claim 1 , wherein the instructions, when executed by the at least one processor, cause the apparatus to:
provide, by the message bus toward an event dispatcher configured to direct the events of the event type toward the set of event queues, the event queue status information.

9. A method, comprising:
maintaining, by a message bus for a set of nodes, a set of event queues for an event type;
determining, by the message bus based on monitoring of the event queues, event queue status information including respective sets of queue status information associated with the respective event queues;
controlling, by the message bus based on the event queue status information, storage of a set of events of the event type in the set of event queues;
modifying, by the message bus based on an indication of a scaling of the set of nodes for the event type based on the event queue status information, a mapping of respective subsets of the event queues to respective ones of the nodes; and
sending, by the message bus toward the set of nodes based on the mapping, the set of events of the event type.

10. The method of claim 9 , further comprising:
instantiating the event queues for the event type based on respective requests to subscribe to the message bus for the event type.

11. The method of claim 9 , wherein, for at least one of the event queues, the respective set of queue status information for the respective event queue comprises at least one of a queue length of the respective event queue, an event arrival rate of the respective event queue, or an event departure rate of the respective event queue.

12. The method of claim 9 , further comprising:
computing, for each of the event queues in the set of event queues based on the respective sets of queue status information associated with the respective event queues, a respective queue score for the respective event queue.

13. The method of claim 12 , wherein the respective queue scores for the respective event queues are configured such that a longer one of the event queues is selected over a shorter one of the event queues, for storing events of the event type, based on an indication that a length of the longer one of the event queues and a length of the shorter one of the event queues are changing at different rates.

14. The method of claim 12 , wherein, for at least one of the event queues, the respective queue score of the respective event queue is based on an exponentially weighted moving average of a queue length of the respective event queue and an exponentially weighted moving average of a departure rate of the respective event queue.

15. The method of claim 9 , further comprising:
providing, by the message bus toward a function manager configured to support the scaling of the set of nodes for the event type, the event queue status information.

16. The method of claim 9 , further comprising:
providing, by the message bus toward an event dispatcher configured to direct the events of the event type toward the set of event queues, the event queue status information.

Assignees

• Nokia Solutions & Networks Oy

Inventors

• Rimac Ivica
• Akkus Istemi Ekin
• Chen Ruichuan
• Stein Manuel
• Hilt Volker

Classifications

• G06F2209/548

  Queue · CPC title

• G06F9/4881

  Scheduling strategies for dispatcher, e.g. round robin, multi-level priority queues · CPC title

• G06F9/546

  Message passing systems or structures, e.g. queues · CPC title

• G06F9/542 Primary

  Event management; Broadcasting; Multicasting; Notifications · CPC title