Trigger based analytics database synchronization

A non-transitory computer-readable medium embodying computer-readable program instructions executable in at least one computing device for synchronization of data between databases that, when executed by the at least one computing device, direct the at least one computing device to at least:

• invoke a trigger based on an operation issued for a record in a transactional database;
• according to the trigger, determine at least one data value to synchronize from the record in the transactional database to an analytics database of an analytics computing system;
• form, by a publisher of a message service executing in the at least one computing device, a message comprising the at least one data value;
• add 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 from data synchronization with the analytics database;
• normalize, 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;
• store, 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
• forward, by a forwarding service executing in the at least one computing device, the at least one normalized data value from the staging table to the analytics database of the analytics computing system over a computer network using a network transfer protocol, wherein the forwarding service initiates a network call to the analytics computing system to synchronize the at least one data value between the transactional database and the analytics database.

A system for synchronization of data between databases, comprising:

• a memory device configured to store computer-readable instructions thereon;
• and
• at least one computing device configured, through execution of the computer-readable instructions, to at least:
• invoke a trigger based on an operation issued for a record in a transactional database;
• according to the trigger, determine at least one data value to synchronize from the record in the transactional database to an analytics database of an analytics computing system;
• form, by a publisher of a message service executing in the at least one computing device, a message comprising the at least one data value;
• add 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 from data synchronization with the analytics database;
• normalize, 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;
• store, 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
• forward, by a forwarding service executing in the at least one computing device, the at least one normalized data value from the staging table to the analytics database of the analytics computing system over a computer network using a network transfer protocol, wherein the forwarding service initiates a network call to the analytics computing system to synchronize the at least one data value between the transactional database and the analytics database.