Method and system for data synchronization

Patent metadata

Field	Value
Publication number	US-11809452-B2
Application number	US-202117444870-A
Country	US
Kind code	B2
Filing date	Aug 11, 2021
Priority date	Aug 11, 2021
Publication date	Nov 7, 2023
Grant date	Nov 7, 2023

Abstract

A method for facilitating data synchronization across a plurality of platforms is provided. The method includes retrieving a change event, the change event corresponding to an event stream from a first platform; parsing the change event to identify a record and a data operation; examining a synchronization database to determine whether a corresponding record is persisted in a database of a second platform; inserting the record into the synchronization database when the corresponding record is not persisted in the platform, the inserted record including a change indicator; and updating, by using the synchronization database, the database of the second platform to include the record.

First claim

What is claimed is:

1. A method for facilitating data synchronization across a plurality of platforms, the method being implemented by at least one processor, the method comprising:
retrieving, by the at least one processor, at least one change event, the at least one change event corresponding to an event stream from at least one first platform;
parsing, by the at least one processor, the at least one change event to identify at least one record and at least one data operation;
examining, by the at least one processor, at least one synchronization database to determine whether at least one corresponding record is persisted in a database of at least one second platform;
inserting, by the at least one processor in the at least one synchronization database, the at least one record when the at least one corresponding record is not persisted in the at least one second platform, the inserted at least one record including a change indicator; and
updating, by the at least one processor using the at least one synchronization database, the database of the at least one second platform to include the at least one record.

2. The method of claim 1 , further comprising:
determining, by the at least one processor after the updating, whether the database of the at least one second platform includes the at least one record;
flagging, by the at least one processor based on a result of the determining, the inserted at least one record in the synchronization database; and
generating, by the at least one processor based on the flagging, at least one service ticket, the at least one service ticket including information that relates to at least one from among the result of the determining and the inserted at least one record in the synchronization database.

3. The method of claim 1 , further comprising:
generating, by the at least one processor, at least one event message that includes the at least one record; and
transmitting, by the at least one processor, the at least one event message to at least one from among the at least one first platform and the at least one second platform to facilitate event auditing.

4. The method of claim 1 , wherein the at least one record is translated based on a characteristic of the at least one second platform prior to the updating.

5. The method of claim 1 , wherein the change indicator includes at least one identifier that represents at least one from among the at least one first platform and the at least one second platform.

6. The method of claim 5 , further comprising:
identifying, by the at least one processor using the change indicator, at least one insertion order for each of a plurality of records in the at least one synchronization database; and
determining, by the at least one processor, an event stream direction by using the identified at least one insertion order.

7. The method of claim 1 , further comprising:
extracting, by the at least one processor, at least one time value for each of a plurality of records in the synchronization database; and
determining, by the at least one processor, at least one latency value based on the extracted at least one time value.

8. The method of claim 1 , further comprising:
identifying, by the at least one processor, at least one feature based on a plurality of records in the synchronization database, the at least one feature relating to an individual trait of a data phenomenon; and
generating, by the at least one processor using the at least one feature, at least one model, the at least one model representing a pattern of errors that relate to the plurality of records in the synchronization database.

9. The method of claim 8 , further comprising:
identifying, by the at least one processor using the generated at least one model, at least one error condition based on the inserted at least one record; and
automatically initiating, by the at least one processor, at least one repair action to resolve the identified at least one error condition.

10. The method of claim 1 , further comprising:
generating, by the at least one processor, at least one dashboard based on a plurality of records in the at least one synchronization database, the at least one dashboard including information relating to at least one from among an event stream direction, a latency value, an error condition, a repair action, an unprocessed workflow, and an event failure rate; and
displaying, by the at least one processor via a graphical user interface, the at least one dashboard.

11. A computing device configured to implement an execution of a method for facilitating data synchronization across a plurality of platforms, the computing device comprising:
a processor;
a memory; and
a communication interface coupled to each of the processor and the memory,
wherein the processor is configured to:
retrieve at least one change event, the at least one change event corresponding to an event stream from at least one first platform;
parse the at least one change event to identify at least one record and at least one data operation;
examine at least one synchronization database to determine whether at least one corresponding record is persisted in a database of at least one second platform;
insert the at least one record into the at least one synchronization database when the at least one corresponding record is not persisted in the at least one second platform, the inserted at least one record including a change indicator; and
update, by using the at least one synchronization database, the database of the at least one second platform to include the at least one record.

12. The computing device of claim 11 , wherein the processor is further configured to:
determine, after the updating, whether the database of the at least one second platform includes the at least one record;
flag, based on a result of the determining, the inserted at least one record in the synchronization database; and
generate, based on the flagging, at least one service ticket, the at least one service ticket including information that relates to at least one from among the result of the determining and the inserted at least one record in the synchronization database.

13. The computing device of claim 11 , wherein the processor is further configured to:
generate at least one event message that includes the at least one record; and
transmit the at least one event message to at least one from among the at least one first platform and the at least one second platform to facilitate event auditing.

14. The computing device of claim 11 , wherein, prior to the updating, the processor is further configured to translate the at least one record based on a characteristic of the at least one second platform.

15. The computing device of claim 11 , wherein the change indicator includes at least one identifier that represents at least one from among the at least one first platform and the at least one second platform.

16. The computing device of claim 15 , wherein the processor is further configured to:
identify, by using the change indicator, at least one insertion order for each of a plurality of records in the at least one synchronization database; and
determine an event stream direction by using the identified at least one insertion order.

17. The computing device of claim 11 , wherein the processor is further configured to:
extract at least one time value for each of a plurality of records in the synchronization database; and
determine at least one latency value based on the extracted at least one time value.

18. The comput

Assignees

• Jpmorgan Chase Bank Na

Inventors

• Devan Stanley M
• Krishnamurthy Satyajit Arivukkodi
• Kommera Naga Virajitha
• Quesenberry David Anthony
• Nieman Kenneth L

Classifications

• G06F16/273 Primary

  Asynchronous replication or reconciliation · CPC title

• G06F11/073

  in a memory management context, e.g. virtual memory or cache management (memory management G06F12/00; testing of static memory units G11C29/00) · CPC title

• G06F11/0727

  in a storage system, e.g. in a DASD or network based storage system (drivers for digital recording or reproducing units G06F3/06; circuits for error detection or correction within digital recording or reproducing units G11B20/18; for distributed storage of data in networks, e.g. transport arrangements for network file system [NFS], storage area networks [SAN] or network attached storage [NAS], H04L67/1097) · CPC title

• G06F11/0751 Primary

  Error or fault detection not based on redundancy (power supply failures G06F1/30; network fault management H04L41/06) · CPC title

• G06F11/0793

  Remedial or corrective actions (recovery from an exception in an instruction pipeline G06F9/3861; by retry G06F11/1402; for recovering from a failure of a protocol instance or entity H04L69/40) · CPC title