US 11,789,935 B2
Data aggregation with microservices
Vivek Ranga Rao, McLean, VA (US); Shenpei Wu, McLean, VA (US); Aparna Keshavamurthy, McLean, VA (US); Madhu Sai Saranya Kachireddy, McLean, VA (US); Coty Kurtz, McLean, VA (US); Shailesh Kurdekar, McLean, VA (US); Krishnakumar Ramamurthy, McLean, VA (US); Prathyusha Ganta, McLean, VA (US); Indulekha Ghandikota, McLean, VA (US); Vishalvikrant Singh, McLean, VA (US); Jesse Gutierrez, McLean, VA (US); and Alexandra Loucks, McLean, VA (US)
Assigned to Capital One Services, LLC, McLean, VA (US)
Filed by Capital One Services, LLC, McLean, VA (US)
Filed on Mar. 15, 2021, as Appl. No. 17/201,466.
Prior Publication US 2022/0292080 A1, Sep. 15, 2022
Int. Cl. G06F 16/23 (2019.01); G06F 16/2455 (2019.01); G06N 3/02 (2006.01); G06F 16/242 (2019.01)
CPC G06F 16/2379 (2019.01) [G06F 16/2329 (2019.01); G06F 16/2358 (2019.01); G06F 16/244 (2019.01); G06F 16/24556 (2019.01); G06N 3/02 (2013.01)] 20 Claims
OG exemplary drawing
 
1. A system for providing real-time updates to a destination application program interface (API) comprising one or more memory devices storing instructions and one or more processors configured to execute the instructions that, when executed, cause operations comprising:
obtaining a database transaction request associated with a first transaction identifier via a first API, wherein the database transaction request comprises a first value;
accessing a second API of a sequential transactions database to store a transaction entry in the sequential transactions database based on the database transaction request;
generating a reversed key by reversing the first transaction identifier;
accessing a third API of an aggregation database to determine whether the aggregation database comprises any transaction aggregation records indexed by the reversed key;
in response to a determination that the aggregation database does not store any transaction aggregation records indexed by the reversed key, generating a transaction aggregation record comprising the first value in the aggregation database, wherein the transaction aggregation record is indexed with the reversed key in the aggregation database;
obtaining an update message indicating an update to the sequential transactions database, wherein the update message comprises a second transaction identifier and a second value, and wherein the first API was not used to update the sequential transactions database;
reversing the second transaction identifier to reconstruct the reversed key;
searching the aggregation database with the reversed key to retrieve the transaction aggregation record;
updating the transaction aggregation record based on the second value; and
sending the transaction aggregation record to the destination API after updating the transaction aggregation record with the second value.