US 2020/0394701 A1 · TRANSFORMATION AND AGGREGATION ENGINE

Abstract

A system has a gateway cluster having a gateway processor for communication with an external processor of an external user using a first protocol and data format. A non-transitory storage medium is configured for storing a database containing unfilled orders associated with the external user. An application cluster has a processor in communication with the storage medium for accessing the database. The gateway processor can communicate with the application processor using a second protocol and data format different from the first protocol and data format. The application processor is configured for fetching and aggregating unfilled orders from the database, and transmitting an aggregation of orders to the external processor via the gateway cluster in response to a number of unfilled orders being at least a threshold number, a size of the aggregation of orders being at least a threshold size, or expiration of a predetermined time period.

Claims20

Dependent claims

A system comprising:

a first gateway cluster having a first gateway processor configured to communicate with a first external processor of a first external user;
a non-transitory machine readable storage medium configured for storing a database;
a first application cluster comprising a first plurality of virtual machines and a second application cluster comprising a second plurality of virtual machines, wherein the first application cluster is configured to:
receive a first message from the first gateway cluster;
access a first set of rules for the first external user from the database;
determine that a first trigger condition is satisfied based on the first message and the first set of rules;
obtain a first lock from a lock manager in response to determining that the first trigger condition is satisfied, wherein the first lock gives exclusive access to a first plurality of orders for the first external user stored in the database to one of the first application cluster and the second application cluster;
aggregate the first plurality of orders for the first external user based on obtaining the first lock;
and
transmit the first plurality of orders to the first external processor via the first gateway cluster.

7 more elements

A method comprising:

receiving a first message from a first gateway cluster;
accessing a first set of rules for a first external user from a database;
determining that a first trigger condition is satisfied based on the first message and the first set of rules;
obtaining a first lock from a lock manager in response to determining that the first trigger condition is satisfied, wherein the first lock gives exclusive access to a first plurality of orders for the first external user stored in the database to one of a first application cluster and a second application cluster;
aggregating the first plurality of orders for the first external user based on obtaining the first lock;
and
transmitting the first plurality of orders to the first external processor via the first gateway cluster.

4 more elements

A non-transitory, machine readable storage medium encoded with program instructions, wherein when a processor executes the programmed instructions, the processor performs the method comprising:

receiving a first message from a first gateway cluster;
accessing a first set of rules for a first external user from a database;
determining that a first trigger condition is satisfied based on the first message and the first set of rules;
obtaining a first lock from a lock manager in response to determining that the first trigger condition is satisfied, wherein the first lock gives exclusive access to a first plurality of orders for the first external user stored in the database to one of a first application cluster and a second application cluster;
aggregating the first plurality of orders for the first external user based on obtaining the first lock;
and
transmitting the first plurality of orders to the first external processor via the first gateway cluster.

4 more elements

Dependencies are inferred from the claim text.

Transformation and aggregation engine

Life of this patent

Transformation and aggregation engine

Life of this patent

Abstract

Claims20