CPC G06F 16/2365 (2019.01) [H04L 67/14 (2013.01)] | 20 Claims |
1. A system for multi-stream data integrity and analysis, the system comprising:
a processing device;
a non-transitory storage device containing instructions when executed by the processing device, causes the processing device to perform steps of:
receive global session data from a streaming or batch data source;
based on one or more data characteristics of the global session data, determine one or more impacted databases;
generate a knowledge graph metadata file for the global session data, wherein the knowledge graph metadata file comprises nodes representing data entries, relationships representing data dependencies, and one or more predictive analytics markers;
assign a global session reference number, a unique graph key, and an integrity counter to the metadata file, wherein the integrity counter triggers an automated rollback process upon detection of compromised data integrity;
generate a unique hash value based on the global session reference number, the unique graph key, and the integrity counter;
store data in one or more upstream, downstream, or analytics databases; and
continuously and dynamically update the knowledge graph metadata file, in real-time, based on the global session data and the integrity counter, permitting the system to proactively identify and mitigate data integrity breaches prior to a propagation in the one or more upstream, downstream, or analytics databases.
|