Consensus key locking with fast local storage for idempotent transactions

A transaction exchange platform comprising:

• at least one processor;
• and
• memory storing instructions that, when executed by the at least one processor, cause the transaction exchange platform to:
• receive, by a locking microservice from a first microservice of a first streaming data platform of the transaction exchange platform and based on a determination that the first microservice requires access to a first resource while processing a transaction object, a request for a lock for the first resource, wherein:
• the first streaming data platform is associated with a first geographic region;
• and
• the transaction exchange platform comprises a second stream data platform associated with a second geographic region different from the first geographic region;
• determine, by the locking microservice and based on querying a local data structure, whether a lock exists for the first resource;
• based on a determination that a lock does not exist for the first resource, transmit, by the locking microservice to a distributed lock manager associated with the transaction exchange platform, an inquiry whether a lock exists for the first resource;
• transmit, by the locking microservice to the distributed lock manager and based on receiving a response indicating that a lock does not exist for the first resource, the request for a lock for the first resource;
• receive, by the locking microservice from the distributed lock manager, a lock for the first resource, wherein the lock is granted based on a consensus protocol indicating that the lock should be granted to the first microservice;
• transmit, by the locking microservice to the first microservice, an indication that a lock for the first resource has been acquired;
• and
• in response to receiving the indication, process, by the first microservice, a first transaction object using the first resource to generate an updated value of the first resource.

One or more non-transitory computer-readable media comprising instructions that, when executed, cause a transaction exchange platform to:

• receive, by a locking microservice from a first microservice of a first streaming data platform of the transaction exchange platform and based on a determination that the first microservice requires access to a first resource while processing a transaction object, a request for a lock for the first resource, wherein:
• the first streaming data platform is associated with a first geographic region;
• and
• the transaction exchange platform comprises a second stream data platform associated with a second geographic region different from the first geographic region;
• determine, by the locking microservice and based on querying a local data structure associated with the first geographic region, whether a lock exists for the first resource;
• based on a determination that a lock does not exist for the first resource, transmit, by the locking microservice to a distributed lock manager associated with the transaction exchange platform, an inquiry whether a lock exists for the first resource;
• transmit, by the locking microservice to the distributed lock manager and based on receiving a response indicating that a lock does not exist for the first resource, the request for a lock for the first resource;
• receive, by the locking microservice from the distributed lock manager, a lock for the first resource, wherein the lock is granted based on a consensus protocol indicating that the lock should be granted to the first microservice;
• transmit, by the locking microservice to the first microservice, an indication that a lock for the first resource has been acquired;
• and
• in response to receiving the indication, process, by the first microservice, a first transaction object using the first resource to generate an updated value of the first resource.