US 11,687,567 B2
Trigger based analytics database synchronization
Zundra Vennaldo Daniel, Atlanta, GA (US); Joshua Glenn Broch, Palo Alto, CA (US); Liny Chandran, Bangalore (IN); Abhishek Mishra, Atlanta, GA (US); Manu Nazareth, Atlanta, GA (US); and Sangeeta Soman, Bangalore (IN)
Assigned to VMWARE, INC., Palo Alto, CA (US)
Filed by VMWARE, INC., Palo Alto, CA (US)
Filed on Jan. 9, 2018, as Appl. No. 15/865,288.
Claims priority of application No. 201741033570 (IN), filed on Sep. 21, 2017.
Prior Publication US 2019/0087478 A1, Mar. 21, 2019
This patent is subject to a terminal disclaimer.
Int. Cl. G06F 16/28 (2019.01); G06F 9/54 (2006.01); G06F 16/23 (2019.01); G06F 16/242 (2019.01); G06F 16/27 (2019.01)
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
OG exemplary drawing
 
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.