Updating records in a real-time storage system

A messaging system comprising:

• a non-relational database configured to store messages exchanged on a messaging platform in a non-relational database;
• a database manager configured to obtain, over time, a sequence of database snapshots of the non-relational database, the sequence of database snapshots including a first database snapshot;
• a task manager configured to execute a database task on the first database snapshot to generate an update log, the update log identifying a plurality of records to be changed or deleted in the non-relational database;
• and
• a change applier configured to determine, for each of the plurality of records identified in the update log, whether or not a record has been updated in the non-relational database after a time instance associated with the database task,
• the change applier configured to apply the change or deletion of the record in the non-relational database in response to the record being determined as not updated after the time instance associated with the database task.

A non-transitory computer-readable medium storing executable instructions that when executed by at least one processor cause the at least one processor to:

• store messages exchanged on a messaging platform in a non-relational database;
• obtain, over time, a sequence of database snapshots of the non-relational database, the sequence of database snapshots including a first database snapshot and a second database snapshot;
• execute a database task on the first database snapshot to generate an update log, the update log identifying a plurality of records to be changed or deleted in the non-relational database;
• determine, for each of the plurality of records identified in the update log, whether or not a record has been updated in the non-relational database after a time instance associated with the database task;
• not apply the change or deletion of the record in the non-relational database in response to the record being determined as updated after the time instance associated with the database task;
• and
• attempt to apply the change or deletion of the record in the non-relational database using the second database snapshot.