US 2024/0403145 A1 · IDEMPOTENT EVENT HANDLING

Abstract

A partition-based method to implement idempotence in an event-driven architecture is provided, which acts to reduce the pressure of database reading and writing, thus improving the performance of event handling. In order to improve parallelism, a consumer cluster (a cluster of multiple consumers that can share the responsibility of processing events) is established such that the events are distributed among different partitions within the cluster. Each partition contains a different consumer worker (with its own cache). An event dispatch module is then used to dispatch events among the consumer workers in a way that keeps the load balanced. In an example embodiment, this is performed by generating a partition identification for an event based on a hash of the context identification of the session established between the user and the application when the event was generated, followed by a modulo operation based on the number of consumer workers in the cluster.

Claims20

Dependent claims

A system comprising:

at least one hardware processor;
and
a computer-readable medium storing instructions that, when executed by the at least one hardware processor, cause the at least one hardware processor to perform operations comprising:
receiving an event from an event producer in an event-driven architecture, the event generated during a first session established between a user and the event producer;
generating a first session identification for the first session, the first session identification being different than a second session identification generated for a second session established between the user and the event producer,
determining a first event consumer worker from a plurality of different event consumer workers based on the first session identification, through a calculation involving the first session identification and a number representing an amount of different event consumer workers;
and
sending the event, and other events that occur during the first session, to the first event consumer worker for processing.

5 more elements

A non-transitory machine-readable medium storing instructions which, when executed by one or more processors, cause the one or more processors to perform operations comprising:

receiving an event from an event producer in an event-driven architecture, the event generated during a first session established between a user and the event producer;
generating a first session identification for the first session, the first session identification being different than a second session identification generated for a second session established between the user and the event producer,
determining a first event consumer worker from a plurality of different event consumer workers based on the first session identification, through a calculation involving the first session identification and a number representing an amount of different event consumer workers;
and
sending the event, and other events that occur during the first session, to the first event consumer worker for processing.

2 more elements

Dependencies are inferred from the claim text.

Idempotent event handling

Life of this patent

Idempotent event handling

Life of this patent

Abstract

Claims20