Snapshots at real time intervals on asynchronous data replication system

A computer system for taking real-time snapshots, the computer system comprising:

• a memory;
• and
• a processor in communication with the memory, wherein the computer system is configured to perform a method, the method comprising:
• calculating a moving weighted average of application bandwidth based on updates to a first data storage made by a first data site;
• calculating a moving weighted average of transmission bandwidth based on replication of the updates to a second data storage managed by a second data site in communication with the first data site;
• identifying coordinated consistency points and calculating time remaining before a next consistency point;
• determining an amount of the updates that can be replicated before the next consistency point based on the average transmission bandwidth;
• making a prediction, using heuristics based on the average application bandwidth, of an amount of additional updates that will be generated on the first data site before the next consistency point;
• and
• flushing pending updates to the second data storage when update accumulation combined with the prediction of update generation on the first data site exceeds the amount of the updates that can be replicated before the next consistency point.

A computer program product for taking real-time snapshots, the computer program product comprising a computer readable storage medium having program instructions embodied therewith, wherein the computer readable storage medium is not a transitory signal per se, the program instructions executable by a processor to perform a method comprising:

• calculating a moving weighted average of application bandwidth based on updates to a first data storage made by a first data site;
• calculating a moving weighted average of transmission bandwidth based on replication of the updates to a second data storage managed by a second data site in communication with the first data site;
• identifying coordinated consistency points and calculating time remaining before a next consistency point;
• determining an amount of the updates that can be replicated before the next consistency point based on the average transmission bandwidth;
• making a prediction, using heuristics based on the average application bandwidth, of an amount of additional updates that will be generated on the first data site before the next consistency point;
• and
• flushing pending updates to the second data storage when update accumulation combined with the prediction of update generation on the first data site exceeds the amount of the updates that can be replicated before the next consistency point.