Batch process monitoring and alerting based on selection of buffer times

• US 10,678,590 B1
• Filed: 12/02/2019
• Issued: 06/09/2020
• Est. Priority Date: 12/02/2019
• Status: Active Grant

• Current Assignee: Capital One Services LLC (Capital One Financial Corporation)
• Original Assignee: Capital One Services LLC (Capital One Financial Corporation)
• Inventors: Sharma, Tanu, Driscoll, Veronica L., Sharma, Vishesh
• Primary Examiner(s): Zhao, Bing
• Application Number:
  US16/700,707
• Time in Patent Office: 190 Days
• Field of Search: None
• CPC Class Codes: G06F 9/466 Transaction processing
• CPC Class Codes: G06F 9/4843 by program, e.g. task dispatcher, supervisor, operating system
• CPC Class Codes: G06F 9/4887 involving deadlines, e.g. rate based, periodic
• CPC Class Codes: G06F 9/542 Event management; Broadcasting; Multicasting; Notifications
• CPC Class Codes: G06F 9/544 Buffers; Shared memory; Pipes
• CPC Class Codes: G06F 9/546 Message passing systems or structures, e.g. queues

Abstract

A system monitors a batch process performed locally or remotely by reading output logs of the batch process during and after execution of the batch process. The system determines a baseline execution duration for the batch process based on previous runs of the batch process on a set of data. Subsequent runs of the batch process are monitored by reading an output log file while the batch process is executing. A buffer time, corresponding to a time range, is added to the baseline execution duration to produce an alert threshold. The system generates alerts and sends the alerts to a messaging system in response to the current execution duration exceeding the alert time.

Claims

1. A method of monitoring batch processes, comprising:

determining, by one or more processors, a baseline execution duration corresponding to a batch process comprising a computation executed on a first data set, wherein the baseline execution duration comprises a time duration based on an execution duration of the computation of the batch process executed on the first data set;

executing, by the one or more processors, the computation of the batch process on a second data set after executing the batch process on the first data set;

determining, by the one or more processors, a current execution duration corresponding to the computation of the batch process on the second data set;

predetermining, by the one or more processors, a plurality of potential buffer times, each of the plurality of potential buffer times associated with an execution time range;

selecting, by the one or more processors, from the predetermined plurality of potential buffer times a buffer time based on the baseline execution duration being within the execution time range associated with the selected buffer time; and

generating, by the one or more processors, an alert in response to the current execution duration being greater than a sum of the baseline execution duration plus the buffer time.

2. The method of claim 1 further comprising:

executing, by the one or more processors, the batch process on the first data set; and

creating a first computer-readable record, comprising data related to an execution duration of the computation, in response to executing the batch process on the first data set, and wherein the determining of the baseline execution duration comprises reading, by the one or more processors, the first computer-readable record.

3. The method of claim 1, wherein the baseline execution duration is based on an aggregate of execution durations of multiple executions of the batch process, including the execution of the batch process on the first data set.

4. The method of claim 1, wherein the determining of the current execution duration comprises reading a second computer-readable record comprising data related to an execution duration of the computation of the batch process executing on the second data set.

5. The method of claim 4, wherein the current execution duration is determined based on a start time corresponding to the batch process executing on the second data set.

6. The method of claim 1, further comprising transmitting the alert to a messaging service.

7. The method of claim 1, further comprising displaying a visual representation of the current execution duration and the baseline execution duration.

8. A system for monitoring a batch process, the system comprising:

a batch executor configured to;

execute a batch process on a first data set, wherein the batch process comprises a computation;

in response to executing the batch process on the first data set, create a first computer-readable record comprising data related to an execution duration of the computation of the batch process;

execute the computation of the batch process on a second data set after executing the batch process on the first data set; and

create, during execution of the batch process on the second data set, a second computer-readable record comprising data related to an execution duration of the computation of the batch process executing on the second data set; and

a monitoring device, coupled to the batch executor, configured to;

determine a baseline execution duration based on the first computer-readable record, wherein the baseline execution duration comprises a time duration based on the execution duration of the computation of the batch process executed on the first data set;

determine, during execution of the batch process on the second data set, a current execution duration based on the second computer-readable record;

predetermine a plurality of potential buffer times, each of the plurality of potential buffer times associated with an execution time range;

select from the predetermined plurality of potential buffer times a buffer time from a plurality of different buffer times based on the baseline execution duration being within the execution time range associated with the selected buffer time; and

generate an alert in response to the current execution duration being greater than a sum of the baseline execution duration plus the buffer duration.

9. The system of claim 8 wherein the determining of the current execution duration comprises reading, from the second computer-readable record, a start time corresponding to the batch process executing on the second data set.

10. The system of claim 8 further comprising an alert service configured to transmit the generated alert to one or more channels of a subscriber-based messaging system.

11. The system of claim 8, further comprising:

a storage memory, wherein the monitoring device is further configured to store the generated alert in the storage; and

an alert service configured to read the alert from the storage and transmit the alert to a subscriber.

12. A non-transitory computer-readable storage medium storing instructions that, when executed by a processor, cause the processor to perform the steps of:

determining, by one or more processors, a baseline execution duration corresponding to a batch process comprising a computation executed on a first data set, wherein the baseline execution duration comprises a time duration based on an execution duration of the computation of the batch process executed on the first data set;

executing, by the one or more processors, the computation of the batch process on a second data set after executing the batch process on the first data set;

determining, by the one or more processors, a current execution duration corresponding to the computation of the batch process on the second data set;

predetermining, by the one or more processors, a plurality of potential buffer times, each of the plurality of potential buffer times associated with an execution time range;

selecting, by the one or more processors, from the predetermined plurality of potential buffer times a buffer time based on the baseline execution duration being within the execution time range associated with the selected buffer time; and

generating, by the one or more processors, an alert in response to the current execution duration being greater than a sum of the baseline execution duration plus the buffer time.

13. The non-transitory computer-readable storage medium of claim 12, wherein the instructions cause the processor to further perform the steps of:

executing, by the one or more processors, the batch process on the first data set; and

creating a first computer-readable record, comprising data related to an execution duration of the computation, in response to executing the batch process on the first data set, and wherein the determining of the baseline execution duration comprises reading, by the one or more processors, the first computer-readable record.

14. The non-transitory computer-readable storage medium of claim 12, wherein the determining of the baseline execution duration comprises determining an aggregate of execution durations of multiple executions of the batch process, including the execution of the batch process on the first data set.

15. The non-transitory computer-readable storage medium of claim 12, wherein the determining of the current execution duration comprises reading a second computer-readable record comprising data related to execution duration of the computation corresponding to the batch executing on the second data set.

16. The non-transitory computer-readable storage medium of claim 15, wherein the current execution duration is determined based on a start time corresponding to the batch process executing on the second data set.