CPC G06Q 10/0635 (2013.01) [G06F 16/2246 (2019.01); G06F 16/2474 (2019.01); G06F 16/26 (2019.01); G06F 17/18 (2013.01); G06F 40/205 (2020.01)] | 16 Claims |
1. A system for dynamically updating a priority queue for scheduling data operations associated with data records, the system comprising:
a processor;
a memory coupled to the processor and storing processor-executable instructions that, when executed, configure the processor to:
schedule, by a data process recommender, for execution over a first time period, data operations for data records associated with a plurality of auditable entities, wherein said scheduling comprises generating a series or sequence of data process segments associated with an audit process for said plurality of auditable entries, and determining priority weights for the respective plurality of data process segments;
receive, by a communication circuit of said system, and store, in said memory, event data from one or more data source devices;
detect that one or more event data objects meet a threshold value for identifying a shift in data operations relevance indicating emergence of a time-varying event associated with the plurality of auditable entities during the first time period, wherein the event data objects includes external news data associated with advanced indication of changes to event data associated with one or more data records corresponding to one or more auditable entities, wherein detecting event data meeting the threshold value includes:
obtaining the external news data including external text-based data;
parsing the external text-based data using natural-language processing to determine frequency indices associated with n-grams of the external text-based data; and
determining that one or more of the determined frequency indices associated with the n-grams of the external text-based data deviates from frequency indices of n-grams of data records corresponding to one or more auditable entities;
based on the event data, traverse a cascading data structure to identify the plurality of auditable entities corresponding to one or more data records, the one or more data records corresponding to at least one branch of the cascading data structure;
generate an updated priority queue for re-allocating data operations prior to expiration of the first time period, wherein re-allocating data operations includes updating priority weights associated with one or more branches of the cascading data structure, the updated priority queue based on event data corresponding to the identified auditable entities relative to event data associated with one or more records corresponding to other auditable entities associated with data records not meeting the threshold value, and wherein said updated priority queue includes updated weights and orders for said series or sequence of data process segments associated with said updated audit process;
transmitting the updated priority queue for scheduling data operations associated with data records of respective auditable entities; and
performing, by said processor of said system, the scheduled data operations in accordance with the updated priority queue and updated series or sequence of data process segments associated with said updated audit process.
|