CPC G06F 16/284 (2019.01) [G06F 9/546 (2013.01); G06F 16/2365 (2019.01); G06F 16/2433 (2019.01); G06F 16/273 (2019.01)] | 20 Claims |
1. A method for synchronization of data between databases, the method comprising:
invoking a trigger based on an operation issued for a record in a transactional database of a computing environment;
according to the trigger, determining at least one data value to synchronize from the record in the transactional database of the computing environment to an analytics database of an analytics computing system;
forming, by a publisher of a message service executing in the computing environment, a message comprising the at least one data value;
adding the message to a message queue of the message service, the message queue comprising a plurality of messages formed by the message service to detach operations in the transactional database of the computing environment from data synchronization with the analytics database of the analytics computing system;
normalizing, by a subscriber of the message service, the at least one data value stored in the message queue into at least one normalized data value in a first at least one extensible markup language (XML) string, wherein the at least one data value comprises a plurality of underlying attributes, and the normalizing comprises discarding a first attribute of the at least one data value and encoding a second attribute of the at least one data value as a second at least one XML string;
storing, by the subscriber, the first at least one XML string and the second at least one XML string to a staging table in the computing environment for data synchronization with the analytics database; and
forwarding, by a forwarding service executing in the computing environment, the at least one normalized data value from the staging table in the computing environment to the analytics database of the analytics computing system over a computer network using a network transfer protocol, wherein the forwarding service initiates an Application Programming Interface (API) call to the analytics computing system to synchronize the at least one data value between the transactional database and the analytics database using the network transfer protocol.
|