Graph database system

A system comprising:

• at least one memory configured to store a graph database system comprising a first graph in a real-time graph database included in an online component and a second graph in an offline graph database included in an offline component, wherein the first graph and the second graph are based on a graph schema;
• and
• a processor coupled to the at least one memory and configured to perform operations that cause the graph database system to:
• receive at least one event that modifies the first graph;
• generate graph logs that include changes to the first graph in the real-time graph database caused by at least one transaction in the at least one event, wherein the changes include mutations to one or more vertices in a plurality of vertices in the first graph and to one or more edges in a plurality of edges in the first graph;
• transmit the graph logs to the offline component in a chronological order;
• modify the second graph in the offline graph database using the graph logs;
• generate snapshots of the second graph at configurable time intervals;
• determine that the first graph includes corrupted data in at least one vertex in the plurality of vertices at a first point in time;
• identify a snapshot from the snapshots of the second graph that was generated at a second point in time prior to the first point in time;
• replay a subset of graph logs from the graph logs on the snapshot from the snapshots, wherein the subset of graph logs from the graph logs is from the second point in time to the first point in time;
• validate data in the second graph based on data generated using the subset of graph logs and the snapshot during the replaying;
• transmit the snapshot and the subset of graph logs from the offline component to the online component in the chronological order;
• update the first graph with the snapshot and the subset of graph logs used to validate the data in the second graph;
• and
• recover the first graph based on the updating.

A method, comprising:

• receiving, at a graph database system that includes a first graph in a real-time graph database included in an online component and a second graph in an offline graph database included in an offline component, at least one event that modifies the first graph, wherein the first graph and the second graph are based on a graph schema;
• generating graph logs that include changes to the first graph in the real-time graph database caused by at least one transaction in the at least one event, wherein the changes include mutations to one or more vertices in a plurality of vertices in the first graph and to one or more edges in a plurality of edges in the first graph;
• transmitting the graph logs to the offline component in a chronological order;
• modifying the second graph in the offline graph database using the graph logs;
• generating snapshots of the second graph at configurable time intervals;
• replaying a subset of graph logs from the graph logs on a snapshot from the snapshots;
• validating data in the second graph based on data generated using the subset of graph logs and the snapshot during the replaying;
• determining that the first graph includes corrupted data in at least one vertex in the plurality of vertices;
• instantiating a new version of the first graph;
• transmitting the graph logs from the offline component to the online component in the chronological order;
• inserting data in the graph logs into the new version of the first graph using operations in the graph logs;
• and
• recovering the first graph based on the inserting.