CN115658445A - Timing task visualization method and device, electronic equipment and storage medium - Google Patents

Abstract

The invention provides a timing task visualization method, which is applied to a visualization system and comprises the following steps: receiving a target timing task message sent by a task system and determining a visual record table of a target timing task according to the target timing task message; acquiring process data of the target timing task from a log system according to a visual meta-configuration table and the target timing task information; and displaying the target timing task according to the visual record list and the process data, wherein the visual record list is determined by processing the received timing task message, the process data corresponding to the timing task is obtained, the state display and the execution process description are carried out on a large number of timing tasks according to the visual record list and the process data, and the overtime task is alarmed by analyzing the average execution time of the past tasks.

Description

Timing task visualization method, device, electronic device and storage medium

technical field

The invention relates to the field of visualization, in particular to a timing task visualization method, device, electronic equipment and storage medium.

Background technique

There are a large number of running batch tasks in the online financial business, and have the following characteristics: 1. The execution time is mostly in the early morning, and it is difficult to monitor in time; 2. There are many tasks and they are interdependent; 3. Some tasks need to monitor process data , to know whether it is normally executed; 4. The task execution time and completion progress are urgent. If there is a delay, the developer needs to be notified in time to deal with it; 5. Timing tasks are distributed among multiple different business subsystems. The conventional solution is to insert execution logs and database records of execution status into the logic of each scheduled task. The disadvantages of using the conventional solution include the following points: 1. The business is highly intrusive, requiring developers to perform repetitive coding irrelevant to the business, which reduces the security of the system; 2. The display is not timely and there is no active reminder function; 3. Maintenance costs High, with more and more projects, it will be difficult to manage many scattered monitoring logic; 4. The view is not intuitive, relying on developers to actively view logs and database records.

Contents of the invention

Based on this, it is necessary to provide a timing task visualization method, device, electronic device and storage medium capable of automatically displaying and monitoring a large amount of timing task execution status and process data for the above technical problems.

In the first aspect, a timing task visualization method is provided, which is applied to a visualization system, and the method includes:

receiving the target timing task message sent by the task system and determining the visual recording table of the target timing task according to the target timing task information;

Acquiring the process data of the target timing task from the log system according to the visualization meta-configuration table and the target timing task information;

The target timed task is displayed according to the visualized record table and the process data.

In one of the embodiments, the receiving the scheduled task message sent by the task system and determining the visual recording table of the target scheduled task according to the scheduled task information includes:

When the timing task status in the timing task message is the first timing task status, determine whether the timing task information is received for the first time;

If yes, then generate the visualization record table according to the timing task information and store the target timing task in the current execution queue;

When the state of the timed task is the state of the second timed task, determine whether the visualized record table exists;

If not, the visualization recording table is generated according to the timed task information.

In one of the embodiments, the obtaining the process data of the target timing task according to the visualization meta-configuration table and the timing task information includes:

When the timed task state in the timed task message is the first timed task state, determine whether the timed task information includes the first process data;

If not, acquiring the first process data from the log system according to the visualization meta-configuration table and the timing task message;

When the state of the timed task is the state of the second timed task, determine whether the information of the timed task contains second process data;

If not, acquiring the second process data from a log system according to the visualization meta-configuration table and the timing task message;

When the timed task state is the third timed task state or the fourth timed task state, delete the target timed task from the current execution queue and acquire third process data according to the timed task information.

In one of the embodiments, the obtaining the first process data from the log system according to the visualization meta-configuration table and the timed task message includes:

determining the metadata configuration of the target scheduled task according to the visualized meta configuration table and the scheduled task message;

The first process data is periodically acquired from the log system according to the current task execution time recorded in the current execution queue and the metadata configuration.

In one of the embodiments, a timing task visualization method is applied to a task system, and the method includes:

When the start execution time of the target scheduled task is reached, determine whether there is a predecessor task of the target scheduled task;

If not, start to execute the target timing task for the log system to record the process data;

determining that the target timed task state is the first timed task state in execution and regularly sending a target timed task message including the first timed task state to the visualization system according to the task execution time threshold;

If yes, determine whether the predecessor task is completed and send the target scheduled task message to the visualization system.

In one of the embodiments, the determining whether the predecessor task is completed and sending the target timing task message to the visualization system includes:

If the predecessor task is not completed, after waiting for the task execution time threshold, determine whether the predecessor task is completed again;

If not, then determine that the state of the target timed task is the state of the second timed task that fails to check and send a target timed task message that includes the state of the second timed task to the visualization system;

An alarm message is sent to the visualization system when it is determined whether the work time for completing the predecessor task exceeds the average task completion time limit.

In one of the embodiments, after sending the target scheduled task message to the visualization system, it includes:

After executing the target timing task, determine whether the execution result of the target timing task is abnormal;

If not, then determine that the target timed task state is a successful third timed task state and send a target timed task message including the third timed task state to the visualization system;

If yes, then determine that the state of the target timed task is a failed fourth state of the timed task, and send a target timed task message including the state of the fourth timed task to the visualization system.

On the other hand, a timing task visualization device is provided, which is applied to a visualization system, and the device includes:

The record determination module is used to receive the target timing task message sent by the task system and determine the visual recording table of the target timing task according to the target timing task information;

An acquisition module, configured to acquire the process data of the target timing task according to the visualization meta-configuration table and the target timing task information;

A display module, configured to display the target timed task according to the visualized record table and the process data.

In one of the embodiments, the record determination module receives the scheduled task message sent by the task system and determines the visual record table of the target scheduled task according to the scheduled task information, including:

When the timing task status in the timing task message is the first timing task status, determine whether the timing task information is received for the first time;

If yes, then generate the visualization record table according to the timing task information and store the target timing task in the current execution queue;

When the state of the timed task is the state of the second timed task, determine whether the visualized record table exists;

If not, the visualization recording table is generated according to the timed task information.

In one of the embodiments, the acquisition module acquires the process data of the target timing task according to the visualization meta-configuration table and the timing task information includes:

When the timed task state in the timed task message is the first timed task state, determine whether the timed task information includes the first process data;

If not, acquiring the first process data from the log system according to the visualization meta-configuration table and the timing task message;

When the state of the timed task is the state of the second timed task, determine whether the information of the timed task contains second process data;

If not, acquiring the second process data from a log system according to the visualization meta-configuration table and the timing task message;

When the timed task state is the third timed task state or the fourth timed task state, delete the target timed task from the current execution queue and acquire third process data according to the timed task information.

In one of the embodiments, the acquiring module acquires the first process data from the log system according to the visualization meta-configuration table and the timed task message includes:

determining the metadata configuration of the target scheduled task according to the visualized meta configuration table and the scheduled task message;

The first process data is periodically acquired from the log system according to the current task execution time recorded in the current execution queue and the metadata configuration.

In one of the embodiments, a timing task visualization device is provided, which is applied to a task system, and the device includes:

A task determination module, configured to determine whether there is a predecessor task of the target timing task when the start execution time of the target timing task is reached;

Execute module, be used for if not, then begin to execute described target timed task so that log system records process data;

A sending module, configured to determine that the target timed task state is the first timed task state in execution and regularly send a target timed task message including the first timed task state to the visualization system according to the task execution time threshold;

The sending module is further configured to, if yes, determine whether the predecessor task is completed and send the target timed task message to the visualization system.

In one of the embodiments, the sending module determines whether the predecessor task is completed and sends the target timing task message to the visualization system includes:

If the predecessor task is not completed, after waiting for the task execution time threshold, determine whether the predecessor task is completed again;

If not, then determine that the state of the target timed task is the state of the second timed task that fails to check and send a target timed task message that includes the state of the second timed task to the visualization system;

An alarm message is sent to the visualization system when it is determined whether the work time for completing the predecessor task exceeds the average task completion time limit.

In one of the embodiments, after the sending module sends the target timing task message to the visualization system, it includes:

After executing the target timing task, determine whether the execution result of the target timing task is abnormal;

If not, then determine that the target timed task state is a successful third timed task state and send a target timed task message including the third timed task state to the visualization system;

If yes, then determine that the state of the target timed task is a failed fourth state of the timed task, and send a target timed task message including the state of the fourth timed task to the visualization system.

In yet another aspect, an electronic device is provided, including a memory, a processor, and a computer program stored on the memory and operable on the processor. When the processor executes the computer program, the following steps are implemented:

receiving the target timing task message sent by the task system and determining the visual recording table of the target timing task according to the target timing task information;

Acquiring the process data of the target timing task from the log system according to the visualization meta-configuration table and the target timing task information;

The target timed task is displayed according to the visualized record table and the process data.

In one of the embodiments, the processor implements the following steps when executing the computer program:

The visual recording table of receiving the scheduled task message sent by the task system and determining the target scheduled task according to the scheduled task information includes:

When the timing task status in the timing task message is the first timing task status, determine whether the timing task information is received for the first time;

If yes, then generate the visualization record table according to the timing task information and store the target timing task in the current execution queue;

When the state of the timed task is the state of the second timed task, determine whether the visualized record table exists;

If not, the visualization recording table is generated according to the timed task information.

In one of the embodiments, the processor implements the following steps when executing the computer program:

The acquiring the process data of the target timing task according to the visualization meta-configuration table and the timing task information includes:

When the timed task state in the timed task message is the first timed task state, determine whether the timed task information includes the first process data;

If not, acquiring the first process data from the log system according to the visualization meta-configuration table and the timing task message;

When the state of the timed task is the state of the second timed task, determine whether the information of the timed task contains second process data;

If not, acquiring the second process data from a log system according to the visualization meta-configuration table and the timing task message;

When the timed task state is the third timed task state or the fourth timed task state, delete the target timed task from the current execution queue and acquire third process data according to the timed task information.

In one of the embodiments, the processor implements the following steps when executing the computer program:

The obtaining the first process data from the log system according to the visualization meta-configuration table and the scheduled task message includes:

determining the metadata configuration of the target scheduled task according to the visualized meta configuration table and the scheduled task message;

The first process data is periodically acquired from the log system according to the current task execution time recorded in the current execution queue and the metadata configuration.

In one of the embodiments, the processor implements the following steps when executing the computer program:

A timing task visualization method applied to a task system, the method comprising:

When the start execution time of the target scheduled task is reached, determine whether there is a predecessor task of the target scheduled task;

If not, start to execute the target timing task for the log system to record the process data;

determining that the target timed task state is the first timed task state in execution and regularly sending a target timed task message including the first timed task state to the visualization system according to the task execution time threshold;

If yes, determine whether the predecessor task is completed and send the target scheduled task message to the visualization system.

In one of the embodiments, the processor implements the following steps when executing the computer program:

The determining whether the predecessor task is completed and sending the target timing task message to the visualization system includes:

If the predecessor task is not completed, after waiting for the task execution time threshold, determine whether the predecessor task is completed again;

If not, then determine that the state of the target timed task is the state of the second timed task that fails to check and send a target timed task message that includes the state of the second timed task to the visualization system;

An alarm message is sent to the visualization system when it is determined whether the work time for completing the predecessor task exceeds the average task completion time limit.

In one of the embodiments, the processor implements the following steps when executing the computer program:

After sending the target timed task message to the visualization system, it includes:

After executing the target timing task, determine whether the execution result of the target timing task is abnormal;

If not, then determine that the target timed task state is a successful third timed task state and send a target timed task message including the third timed task state to the visualization system;

If yes, then determine that the state of the target timed task is a failed fourth state of the timed task, and send a target timed task message including the state of the fourth timed task to the visualization system.

In yet another aspect, a computer-readable storage medium is provided, on which a computer program is stored, and when the computer program is executed by a processor, the following steps are implemented:

receiving the target timing task message sent by the task system and determining the visual recording table of the target timing task according to the target timing task information;

Acquiring the process data of the target timing task from the log system according to the visualization meta-configuration table and the target timing task information;

The target timed task is displayed according to the visualized record table and the process data.

In one of the embodiments, when the computer program is executed by the processor, the following steps are implemented:

The visual recording table of receiving the scheduled task message sent by the task system and determining the target scheduled task according to the scheduled task information includes:

When the timing task status in the timing task message is the first timing task status, determine whether the timing task information is received for the first time;

If yes, then generate the visualization record table according to the timing task information and store the target timing task in the current execution queue;

When the state of the timed task is the state of the second timed task, determine whether the visualized record table exists;

If not, the visualization recording table is generated according to the timed task information.

In one of the embodiments, when the computer program is executed by the processor, the following steps are implemented:

The acquiring the process data of the target timing task according to the visualization meta-configuration table and the timing task information includes:

When the timed task state in the timed task message is the first timed task state, determine whether the timed task information includes the first process data;

If not, acquiring the first process data from the log system according to the visualization meta-configuration table and the timing task message;

When the state of the timed task is the state of the second timed task, determine whether the information of the timed task contains second process data;

If not, acquiring the second process data from a log system according to the visualization meta-configuration table and the timing task message;

When the timed task state is the third timed task state or the fourth timed task state, delete the target timed task from the current execution queue and acquire third process data according to the timed task information.

In one of the embodiments, when the computer program is executed by the processor, the following steps are implemented:

The obtaining the first process data from the log system according to the visualization meta-configuration table and the scheduled task message includes:

determining the metadata configuration of the target scheduled task according to the visualized meta configuration table and the scheduled task message;

The first process data is periodically acquired from the log system according to the current task execution time recorded in the current execution queue and the metadata configuration.

In one of the embodiments, when the computer program is executed by the processor, the following steps are implemented:

A timing task visualization method applied to a task system, the method comprising:

When the start execution time of the target scheduled task is reached, determine whether there is a predecessor task of the target scheduled task;

If not, start to execute the target timing task for the log system to record the process data;

determining that the target timed task state is the first timed task state in execution and regularly sending a target timed task message including the first timed task state to the visualization system according to the task execution time threshold;

If yes, determine whether the predecessor task is completed and send the target scheduled task message to the visualization system.

In one of the embodiments, when the computer program is executed by the processor, the following steps are implemented:

The determining whether the predecessor task is completed and sending the target timing task message to the visualization system includes:

If the predecessor task is not completed, after waiting for the task execution time threshold, determine whether the predecessor task is completed again;

If not, then determine that the state of the target timed task is the state of the second timed task that fails to check and send a target timed task message that includes the state of the second timed task to the visualization system;

An alarm message is sent to the visualization system when it is determined whether the work time for completing the predecessor task exceeds the average task completion time limit.

In one of the embodiments, when the computer program is executed by the processor, the following steps are implemented:

After sending the target timed task message to the visualization system, it includes:

After executing the target timing task, determine whether the execution result of the target timing task is abnormal;

If not, then determine that the target timed task state is a successful third timed task state and send a target timed task message including the third timed task state to the visualization system;

If yes, then determine that the state of the target timed task is a failed fourth state of the timed task, and send a target timed task message including the state of the fourth timed task to the visualization system.

Receive the target timing task message sent by the task system and determine the visual recording table of the target timing task according to the target timing task information; obtain the process data of the target timing task from the log system according to the visualization meta configuration table and the target timing task information ; Displaying the target timing task according to the visualization record table and the process data, wherein the visualization record table is determined by processing the received timing task message and the process data corresponding to the timing task is obtained, and multiple displays are displayed according to the visualization record table and process data Timed task status and other specific data.

Description of drawings

FIG. 1 is a schematic flow diagram of a timing task visualization method applied to a visualization system;

Fig. 2 is a schematic diagram of the steps of the timing task visualization method applied to the visualization system;

Fig. 3 is a schematic flow chart of a timing task visualization method applied to a task system;

Figure 4 is an example grayscale image of a scheduled task;

Fig. 5 is a schematic structural diagram of a timing task visualization device applied to a visualization system;

FIG. 6 is an internal structure diagram of a computer device in an embodiment of the present invention.

Detailed ways

In order to make the purpose, technical solution and advantages of the present application clearer, the present application will be further described in detail below in conjunction with the accompanying drawings and embodiments. It should be understood that the specific embodiments described here are only used to explain the present application, and are not intended to limit the present application.

The timing task visualization method provided in the present application can be applied to the schematic flowchart of the timing task visualization method applied to a visualization system as shown in FIG. 1 . Wherein, the visual record table is determined through the timed task state in the received timed task message, and the process data corresponding to the timed task is obtained, and multiple timed task states and other specific data are displayed according to the visualized record table and process data.

In one embodiment, as shown in FIG. 2, the present invention provides a timing task visualization method, which is applied to a visualization system, and the method includes:

S201. Receive a target scheduled task message sent by the task system and determine a visual record table of the target scheduled task according to the target scheduled task information;

S202. Obtain the process data of the target scheduled task from the log system according to the visualization meta-configuration table and the target scheduled task information;

S203. Display the target scheduled task according to the visualized record table and the process data.

Specifically, the visualized record table is determined by processing the received timed task message and the process data corresponding to the timed task is acquired, and multiple timed task states and other specific data are displayed according to the visualized record table and process data.

In one of the embodiments, the receiving the scheduled task message sent by the task system and determining the visual recording table of the target scheduled task according to the scheduled task information includes:

When the timing task status in the timing task message is the first timing task status, determine whether the timing task information is received for the first time;

If yes, then generate the visualization record table according to the timing task information and store the target timing task in the current execution queue;

When the state of the timed task is the state of the second timed task, determine whether the visualized record table exists;

If not, the visualization recording table is generated according to the timed task information.

Specifically, after receiving the scheduled task message containing the status of the first scheduled task (executing), determine whether the scheduled task is received for the first time. If so, it means that there is no visual record table corresponding to the scheduled task. The information generates a visual record table, in which the scheduled task information includes not only the status of the scheduled task, but also the task code, task name, task output, task start time, task end time, task creation time, etc., and the corresponding visual record is generated according to the above task-related information surface. When receiving the scheduled task message including the status of the second scheduled task, it is determined whether there is a visualized record table of the current scheduled task, and if not, a visualized record table is generated based on the scheduled task message similarly. If a scheduled task message containing the third scheduled task status or the fourth scheduled task status is received, since the scheduled task message containing the first scheduled task status has already been received, the visual record table of the current scheduled task has been generated, so there is no need to repeat the operation.

In one of the embodiments, the obtaining the process data of the target timing task according to the visualization meta-configuration table and the timing task information includes:

When the timed task state in the timed task message is the first timed task state, determine whether the timed task information includes the first process data;

If not, acquiring the first process data from the log system according to the visualization meta-configuration table and the timing task message;

When the state of the timed task is the state of the second timed task, determine whether the information of the timed task contains second process data;

If not, acquiring the second process data from a log system according to the visualization meta-configuration table and the timing task message;

When the timed task state is the third timed task state or the fourth timed task state, delete the target timed task from the current execution queue and acquire third process data according to the timed task information.

Specifically, when a scheduled task message containing the status of the second scheduled task is received, since the predecessor task is still executing and the scheduled task is waiting to be executed at this time, the second process data at this time must contain the words that the scheduled task check failed, if It also includes the second process data generated during the execution of the pre-task, so there is no need to query the log system based on the visualization meta-configuration table. Among them, query the second process recorded in the log system according to the task code, task name, task output, task start time, task end time, task creation time, etc. Data (including the number of tasks, time and related task data for performing predecessor tasks). When receiving a scheduled task message containing the third scheduled task status or the fourth scheduled task status, delete the scheduled task from the current execution queue and the process data at this time is the scheduled task name + execution success/execution failure, such as cash withdrawal receipt The data of the successful execution of the shape transfer task is the last piece of process data generated by executing the scheduled task, and there is no need to query the log system. In addition, when the scheduled task message contains alarm information, there is no need to query the log system. According to the alarm message "predecessor task (cash withdrawal business penalty interest reduction task) error" and the visual record table, the predecessor task error is displayed.

In one of the embodiments, the obtaining the first process data from the log system according to the visualization meta-configuration table and the timed task message includes:

determining the metadata configuration of the target scheduled task according to the visualized meta configuration table and the scheduled task message;

The first process data is periodically acquired from the log system according to the current task execution time recorded in the current execution queue and the metadata configuration.

Specifically, when a scheduled task message containing the status of the first scheduled task is received and there is no relevant process data in the scheduled task message, assuming that the task start time is 13:00:00, it is known from the current execution queue that the current execution time of the task is 13:30:00, then according to the specific task name (cash withdrawal business penalty interest reduction task) and task code (20) contained in the scheduled task message and the template "CREATE TABLE`vipshop_credit_job_task_record`(

`id` bigint(20) unsigned NOT NULL AUTO_INCREMENT COMMENT 'id',

`job_code` varchar(100) NOT NULL DEFAULT "COMMENT'job code',

`job_name` varchar(100) NOT NULL DEFAULT "COMMENT'job name',

)ENGINE=InnoDB AUTO_INCREMENT=26693 DEFAULT CHARSET=utf8

COMMENT='metadata configuration'" to query the first process data recorded in the log system during the period of 13:00:00-13:30:00 (including the number of tasks to perform scheduled tasks, specific time and related task data, etc.).

In one of the embodiments, a timing task visualization method is applied to a task system, and the method includes:

When the start execution time of the target scheduled task is reached, determine whether there is a predecessor task of the target scheduled task;

If not, start to execute the target timing task for the log system to record the process data;

determining that the target timed task state is the first timed task state in execution and regularly sending a target timed task message including the first timed task state to the visualization system according to the task execution time threshold;

If yes, determine whether the predecessor task is completed and send the target scheduled task message to the visualization system.

Specifically, as shown in Figure 3, when the scheduled task reaches the start time of the scheduled task, first determine whether the current scheduled task has a predecessor task, where as shown in Figure 4, the next task (timed task) is dependent on the previous task (predecessor task) can be successfully executed only after completion, for example, a scheduled task (cash withdrawal IOU form transfer task) reaches the trigger time of the scheduled task, because there is no predecessor task, so the current scheduled task will be executed directly and the first scheduled task will be sent periodically The target timing task information of the state (in progress) is sent to the visualization system. When the timing task is executed, the log system will store the timing task in the work set and record the process data generated during the execution process; When the task is triggered, it is determined that it has a predecessor task (cash withdrawal IOU form transfer task). At this time, it is necessary to determine whether the predecessor task is completed.

In one of the embodiments, the determining whether the predecessor task is completed and sending the target timing task message to the visualization system includes:

If the predecessor task is not completed, after waiting for the task execution time threshold, determine whether the predecessor task is completed again;

If not, then determine that the state of the target timed task is the state of the second timed task that fails to check and send a target timed task message that includes the state of the second timed task to the visualization system;

An alarm message is sent to the visualization system when it is determined whether the work time for completing the predecessor task exceeds the average task completion time limit.

Concretely, as mentioned above, when the preceding task (the transfer task of cash withdrawal form) is completed, the scheduled task (cash withdrawal and staged task) is normally executed; failure) to the visualization system, after waiting for the task execution time threshold (such as one minute set by the user), continue to detect whether the predecessor task is completed and send the corresponding timing task message to the visualization system, the current predecessor task is completed in the average task If it is not completed within the time limit (such as one hour), the cash withdrawal installment task will not be executed and a scheduled task message containing alarm information will be sent to the visualization system to remind users to check for abnormal problems.

In one of the embodiments, after sending the target scheduled task message to the visualization system, it includes:

After executing the target timing task, determine whether the execution result of the target timing task is abnormal;

If not, then determine that the target timed task state is a successful third timed task state and send a target timed task message including the third timed task state to the visualization system;

If yes, then determine that the state of the target timed task is a failed fourth state of the timed task, and send a target timed task message including the state of the fourth timed task to the visualization system.

Specifically, as described above, after the task system successfully executes the scheduled task (cash withdrawal, installment and scheduled task), at this time, the execution of the scheduled task ends and the execution result is determined to be normal, and then sends a scheduled task message containing the status of the third scheduled task (success) Go to the visualization system and when the trigger time of the scheduled task corresponding to the next scheduled task (daily channel bill penalty interest synchronization task) is reached, start to execute the daily channel bill penalty interest synchronization task. Wherein, if the timing task is executed abnormally within the average task completion time limit, continue to execute the timing task and send a timing task message including the status of the first timing task to the visualization system. If the timed task has not been completed beyond the average task completion time limit, and the execution of the timed task ends at this time and it is confirmed that the execution result is abnormal, then send a timed task message containing the fourth timed task status (failure) to the visualization system and stop executing the task list The daily channel bill penalty interest synchronization task and other scheduled tasks in , of course, will not affect the execution of scheduled tasks in other task lists.

The scheme of the present application has the following beneficial effects:

1) Realize the visualization of a large number of timed tasks through message event-driven and asynchronous monitoring of execution progress, reducing the work pressure of users;

2) It supports multiple ways to obtain the status of scheduled tasks, such as actively scanning logs and receiving message parameters, and alarms overtime tasks by analyzing the average execution time of past tasks;

3) Support Web and App multi-terminals to view task execution progress.

It should be understood that although the various steps in the flow chart of FIG. 2 are displayed sequentially as indicated by the arrows, these steps are not necessarily executed sequentially in the order indicated by the arrows. Unless otherwise specified herein, there is no strict order restriction on the execution of these steps, and these steps can be executed in other orders. Moreover, at least some of the steps in FIG. 2 may include multiple sub-steps or multiple stages. These sub-steps or stages are not necessarily executed at the same time, but may be executed at different times. The execution of these sub-steps or stages The order is not necessarily performed sequentially, but may be performed alternately or alternately with at least a part of other steps or sub-steps or stages of other steps.

In one embodiment, as shown in FIG. 5, a timing task visualization device is provided, which is applied to a visualization system, and the device includes:

A record determination module 501, configured to receive a target timed task message sent by the task system and determine a visual record table of the target timed task according to the target timed task information;

An acquisition module 502, configured to acquire the process data of the target scheduled task according to the visualization meta-configuration table and the target scheduled task information;

A display module 503, configured to display the target timed task according to the visualized record table and the process data.

In one of the embodiments, the record determination module receives the scheduled task message sent by the task system and determines the visual record table of the target scheduled task according to the scheduled task information, including:

When the timing task status in the timing task message is the first timing task status, determine whether the timing task information is received for the first time;

If yes, then generate the visualization record table according to the timing task information and store the target timing task in the current execution queue;

When the state of the timed task is the state of the second timed task, determine whether the visualized record table exists;

If not, the visualization recording table is generated according to the timed task information.

In one of the embodiments, the acquisition module acquires the process data of the target timing task according to the visualization meta-configuration table and the timing task information includes:

When the timed task state in the timed task message is the first timed task state, determine whether the timed task information includes the first process data;

If not, acquiring the first process data from the log system according to the visualization meta-configuration table and the timing task message;

When the state of the timed task is the state of the second timed task, determine whether the information of the timed task contains second process data;

If not, acquiring the second process data from a log system according to the visualization meta-configuration table and the timing task message;

When the timed task state is the third timed task state or the fourth timed task state, delete the target timed task from the current execution queue and acquire third process data according to the timed task information.

In one of the embodiments, the acquiring module acquires the first process data from the log system according to the visualization meta-configuration table and the timed task message includes:

determining the metadata configuration of the target scheduled task according to the visualized meta configuration table and the scheduled task message;

The first process data is periodically acquired from the log system according to the current task execution time recorded in the current execution queue and the metadata configuration.

In one of the embodiments, a timing task visualization device is provided, which is applied to a task system, and the device includes:

A task determination module 504, configured to determine whether there is a predecessor task of the target timing task when the start execution time of the target timing task is reached;

Executing module 505, is used for if not, then start to execute described target timed task for log system to record process data;

The sending module 506 is configured to determine that the state of the target timed task is the first timed task state in execution and regularly send a target timed task message including the state of the first timed task to the visualization system according to the task execution time threshold ;

The sending module 506 is further configured to, if yes, determine whether the predecessor task is completed and send the target timed task message to the visualization system.

In one of the embodiments, the sending module determines whether the predecessor task is completed and sends the target timing task message to the visualization system includes:

If the predecessor task is not completed, after waiting for the task execution time threshold, determine whether the predecessor task is completed again;

If not, then determine that the state of the target timed task is the state of the second timed task that fails to check and send a target timed task message that includes the state of the second timed task to the visualization system;

An alarm message is sent to the visualization system when it is determined whether the work time for completing the predecessor task exceeds the average task completion time limit.

In one of the embodiments, after the sending module sends the target timing task message to the visualization system, it includes:

After executing the target timing task, determine whether the execution result of the target timing task is abnormal;

If not, then determine that the target timed task state is a successful third timed task state and send a target timed task message including the third timed task state to the visualization system;

If yes, then determine that the state of the target timed task is a failed fourth state of the timed task, and send a target timed task message including the state of the fourth timed task to the visualization system.

For the specific limitations of the timed task visualization device, please refer to the above-mentioned definition of the timed task visualization method, which will not be repeated here. Each module in the above-mentioned timed task visualization device can be fully or partially realized by software, hardware and a combination thereof. The above-mentioned modules can be embedded in or independent of the processor in the computer device in the form of hardware, and can also be stored in the memory of the computer device in the form of software, so that the processor can invoke and execute the corresponding operations of the above-mentioned modules.

In one embodiment, a computer device is provided. The computer device may be a terminal, and its internal structure may be as shown in FIG. 6 . The computer device includes a processor, a memory, a network interface, a display screen and an input device connected through a system bus. Wherein, the processor of the computer device is used to provide calculation and control capabilities. The memory of the computer device includes a non-volatile storage medium and an internal memory. The non-volatile storage medium stores an operating system and computer programs. The internal memory provides an environment for the operation of the operating system and computer programs in the non-volatile storage medium. The network interface of the computer device is used to communicate with an external terminal via a network connection. When the computer program is executed by the processor, the alarm information processing method can be realized. The display screen of the computer device may be a liquid crystal display screen or an electronic ink display screen, and the input device of the computer device may be a touch layer covered on the display screen, or a button, a trackball or a touch pad provided on the casing of the computer device , and can also be an external keyboard, touchpad, or mouse.

Those skilled in the art can understand that the structure shown in FIG. 6 is only a block diagram of a part of the structure related to the solution of this application, and does not constitute a limitation on the computer equipment to which the solution of this application is applied. The specific computer equipment can be More or fewer components than shown in the figures may be included, or some components may be combined, or have a different arrangement of components.

In one embodiment, an electronic device is provided, including a memory, a processor, and a computer program stored on the memory and operable on the processor, and the processor implements the following steps when executing the computer program:

receiving the target timing task message sent by the task system and determining the visual recording table of the target timing task according to the target timing task information;

Acquiring the process data of the target timing task from the log system according to the visualization meta-configuration table and the target timing task information;

The target timed task is displayed according to the visualized record table and the process data.

In one of the embodiments, the processor implements the following steps when executing the computer program:

The visual recording table of receiving the scheduled task message sent by the task system and determining the target scheduled task according to the scheduled task information includes:

When the timing task status in the timing task message is the first timing task status, determine whether the timing task information is received for the first time;

If yes, then generate the visualization record table according to the timing task information and store the target timing task in the current execution queue;

When the state of the timed task is the state of the second timed task, determine whether the visualized record table exists;

If not, the visualization recording table is generated according to the timed task information.

In one of the embodiments, the processor implements the following steps when executing the computer program:

The acquiring the process data of the target timing task according to the visualization meta-configuration table and the timing task information includes:

When the timed task state in the timed task message is the first timed task state, determine whether the timed task information includes the first process data;

If not, acquiring the first process data from the log system according to the visualization meta-configuration table and the timing task message;

When the state of the timed task is the state of the second timed task, determine whether the information of the timed task contains second process data;

If not, acquiring the second process data from a log system according to the visualization meta-configuration table and the timing task message;

When the timed task state is the third timed task state or the fourth timed task state, delete the target timed task from the current execution queue and acquire third process data according to the timed task information.

In one of the embodiments, the processor implements the following steps when executing the computer program:

The obtaining the first process data from the log system according to the visualization meta-configuration table and the scheduled task message includes:

determining the metadata configuration of the target scheduled task according to the visualized meta configuration table and the scheduled task message;

The first process data is periodically acquired from the log system according to the current task execution time recorded in the current execution queue and the metadata configuration.

In one of the embodiments, the processor implements the following steps when executing the computer program:

A timing task visualization method applied to a task system, the method comprising:

When the start execution time of the target scheduled task is reached, determine whether there is a predecessor task of the target scheduled task;

If not, start to execute the target timing task for the log system to record the process data;

determining that the target timed task state is the first timed task state in execution and regularly sending a target timed task message including the first timed task state to the visualization system according to the task execution time threshold;

If yes, determine whether the predecessor task is completed and send the target scheduled task message to the visualization system.

In one of the embodiments, the processor implements the following steps when executing the computer program:

The determining whether the predecessor task is completed and sending the target timing task message to the visualization system includes:

If the predecessor task is not completed, after waiting for the task execution time threshold, determine whether the predecessor task is completed again;

If not, then determine that the state of the target timed task is the state of the second timed task that fails to check and send a target timed task message that includes the state of the second timed task to the visualization system;

An alarm message is sent to the visualization system when it is determined whether the work time for completing the predecessor task exceeds the average task completion time limit.

In one of the embodiments, the processor implements the following steps when executing the computer program:

After sending the target timed task message to the visualization system, it includes:

After executing the target timing task, determine whether the execution result of the target timing task is abnormal;

If not, then determine that the target timed task state is a successful third timed task state and send a target timed task message including the third timed task state to the visualization system;

If yes, then determine that the state of the target timed task is a failed fourth state of the timed task, and send a target timed task message including the state of the fourth timed task to the visualization system.

In one embodiment, a computer-readable storage medium is provided, on which a computer program is stored, and when the computer program is executed by a processor, the following steps are implemented:

receiving the target timing task message sent by the task system and determining the visual recording table of the target timing task according to the target timing task information;

Acquiring the process data of the target timing task from the log system according to the visualization meta-configuration table and the target timing task information;

The target timed task is displayed according to the visualized record table and the process data.

In one of the embodiments, when the computer program is executed by the processor, the following steps are implemented:

The visual recording table of receiving the scheduled task message sent by the task system and determining the target scheduled task according to the scheduled task information includes:

When the timing task status in the timing task message is the first timing task status, determine whether the timing task information is received for the first time;

If yes, then generate the visualization record table according to the timing task information and store the target timing task in the current execution queue;

When the state of the timed task is the state of the second timed task, determine whether the visualized record table exists;

If not, the visualization recording table is generated according to the timed task information.

In one of the embodiments, when the computer program is executed by the processor, the following steps are implemented:

The acquiring the process data of the target timing task according to the visualization meta-configuration table and the timing task information includes:

When the timed task state in the timed task message is the first timed task state, determine whether the timed task information includes the first process data;

If not, acquiring the first process data from the log system according to the visualization meta-configuration table and the timing task message;

When the state of the timed task is the state of the second timed task, determine whether the information of the timed task contains second process data;

If not, acquiring the second process data from a log system according to the visualization meta-configuration table and the timing task message;

When the timed task state is the third timed task state or the fourth timed task state, delete the target timed task from the current execution queue and acquire third process data according to the timed task information.

In one of the embodiments, when the computer program is executed by the processor, the following steps are implemented:

The obtaining the first process data from the log system according to the visualization meta-configuration table and the scheduled task message includes:

determining the metadata configuration of the target scheduled task according to the visualized meta configuration table and the scheduled task message;

The first process data is periodically acquired from the log system according to the current task execution time recorded in the current execution queue and the metadata configuration.

In one of the embodiments, when the computer program is executed by the processor, the following steps are implemented:

A timing task visualization method applied to a task system, the method comprising:

When the start execution time of the target scheduled task is reached, determine whether there is a predecessor task of the target scheduled task;

If not, start to execute the target timing task for the log system to record the process data;

determining that the target timed task state is the first timed task state in execution and regularly sending a target timed task message including the first timed task state to the visualization system according to the task execution time threshold;

If yes, determine whether the predecessor task is completed and send the target scheduled task message to the visualization system.

In one of the embodiments, when the computer program is executed by the processor, the following steps are implemented:

The determining whether the predecessor task is completed and sending the target timing task message to the visualization system includes:

If the predecessor task is not completed, after waiting for the task execution time threshold, determine whether the predecessor task is completed again;

If not, then determine that the state of the target timed task is the state of the second timed task that fails to check and send a target timed task message that includes the state of the second timed task to the visualization system;

An alarm message is sent to the visualization system when it is determined whether the work time for completing the predecessor task exceeds the average task completion time limit.

In one of the embodiments, when the computer program is executed by the processor, the following steps are implemented:

After sending the target timed task message to the visualization system, it includes:

After executing the target timing task, determine whether the execution result of the target timing task is abnormal;

If not, then determine that the target timed task state is a successful third timed task state and send a target timed task message including the third timed task state to the visualization system;

If yes, then determine that the state of the target timed task is a failed fourth state of the timed task, and send a target timed task message including the state of the fourth timed task to the visualization system.

Those of ordinary skill in the art can understand that all or part of the processes in the methods of the above embodiments can be implemented through computer programs to instruct related hardware, and the computer programs can be stored in a non-volatile computer-readable memory In the medium, when the computer program is executed, it may include the processes of the embodiments of the above-mentioned methods. Wherein, any references to memory, storage, database or other media used in the various embodiments provided in the present application may include non-volatile and/or volatile memory. Nonvolatile memory can include read only memory (ROM), programmable ROM (PROM), electrically programmable ROM (EPROM), electrically erasable programmable ROM (EEPROM), or flash memory. Volatile memory can include random access memory (RAM) or external cache memory. By way of illustration and not limitation, RAM is available in many forms such as Static RAM (SRAM), Dynamic RAM (DRAM), Synchronous DRAM (SDRAM), Double Data Rate SDRAM (DDRSDRAM), Enhanced SDRAM (ESDRAM), Synchronous Chain Synchlink DRAM (SLDRAM), memory bus (Rambus) direct RAM (RDRAM), direct memory bus dynamic RAM (DRDRAM), and memory bus dynamic RAM (RDRAM), etc.

The technical features of the above embodiments can be combined arbitrarily. To make the description concise, all possible combinations of the technical features in the above embodiments are not described. However, as long as there is no contradiction in the combination of these technical features, they should be It is considered to be within the range described in this specification.

The above-mentioned embodiments only represent several implementation modes of the present application, and the description thereof is relatively specific and detailed, but it should not be construed as limiting the scope of the patent for the invention. It should be noted that those skilled in the art can make several modifications and improvements without departing from the concept of the present application, and these all belong to the protection scope of the present application. Therefore, the scope of protection of the patent application should be based on the appended claims.

Claims (10)

1. A timing task visualization method, applied to a visualization system, said method comprising: receiving the target timing task message sent by the task system and determining the visual recording table of the target timing task according to the target timing task information; Acquiring the process data of the target timing task from the log system according to the visualization meta-configuration table and the target timing task information; The target timed task is displayed according to the visualized record table and the process data. 2. The method according to claim 1, wherein the receiving the scheduled task message sent by the task system and determining the visual recording table of the target scheduled task according to the scheduled task information includes: When the timing task status in the timing task message is the first timing task status, determine whether the timing task information is received for the first time; If yes, then generate the visualization record table according to the timing task information and store the target timing task in the current execution queue; When the state of the timed task is the state of the second timed task, determine whether the visualized record table exists; If not, the visualization recording table is generated according to the timed task information. 3. The method according to claim 2, wherein said obtaining the process data of the target timing task according to the visualization element configuration table and the timing task information comprises: When the timed task state in the timed task message is the first timed task state, determine whether the timed task information includes the first process data; If not, acquiring the first process data from the log system according to the visualization meta-configuration table and the timing task message; When the state of the timed task is the state of the second timed task, determine whether the information of the timed task contains second process data; If not, acquiring the second process data from a log system according to the visualization meta-configuration table and the timing task message; When the timed task state is the third timed task state or the fourth timed task state, delete the target timed task from the current execution queue and acquire third process data according to the timed task information. 4. The method according to claim 3, wherein said obtaining the first process data from the log system according to the visualization element configuration table and the timing task message comprises: determining the metadata configuration of the target scheduled task according to the visualized meta configuration table and the scheduled task message; The first process data is periodically acquired from the log system according to the current task execution time recorded in the current execution queue and the metadata configuration. 5. A timing task visualization method applied to a task system, the method comprising: When the start execution time of the target scheduled task is reached, determine whether there is a predecessor task of the target scheduled task; If not, start to execute the target timing task for the log system to record the process data; determining that the target timed task state is the first timed task state in execution and regularly sending a target timed task message including the first timed task state to the visualization system according to the task execution time threshold; If yes, determine whether the predecessor task is completed and send the target scheduled task message to the visualization system. 6. The method according to claim 5, wherein the determining whether the predecessor task is completed and sending the target timing task message to the visualization system comprises: If the predecessor task is not completed, after waiting for the task execution time threshold, determine whether the predecessor task is completed again; If not, then determine that the state of the target timed task is the state of the second timed task that fails to check and send a target timed task message that includes the state of the second timed task to the visualization system; An alarm message is sent to the visualization system when it is determined whether the work time for completing the predecessor task exceeds the average task completion time limit. 7. The method according to claim 5, characterized in that, after sending the target timing task message to the visualization system, comprising: After executing the target timing task, determine whether the execution result of the target timing task is abnormal; If not, then determine that the target timed task state is a successful third timed task state and send a target timed task message including the third timed task state to the visualization system; If yes, then determine that the state of the target timed task is a failed fourth state of the timed task, and send a target timed task message including the state of the fourth timed task to the visualization system. 8. A timing task visualization device applied to a visualization system, said device comprising: The record determination module is used to receive the target timing task message sent by the task system and determine the visual recording table of the target timing task according to the target timing task information; An acquisition module, configured to acquire the process data of the target timing task according to the visualization meta-configuration table and the target timing task information; A display module, configured to display the target timed task according to the visualized record table and the process data. 9. An electronic device, characterized in that it comprises: one or more processors; and memory associated with the one or more processors, the memory being used to store program instructions that, when read and executed by the one or more processors, execute The method according to any one of claims 1-7. 10. A computer storage medium, wherein a computer program is stored thereon, wherein when the program is executed by a processor, the method according to any one of claims 1-7 is realized.

Images