CN111858234A - Task execution method, device, equipment and medium - Google Patents
Task execution method, device, equipment and medium Download PDFInfo
- Publication number
- CN111858234A CN111858234A CN202010567664.1A CN202010567664A CN111858234A CN 111858234 A CN111858234 A CN 111858234A CN 202010567664 A CN202010567664 A CN 202010567664A CN 111858234 A CN111858234 A CN 111858234A
- Authority
- CN
- China
- Prior art keywords
- task
- state
- configuration information
- flow
- real
- Prior art date
- Legal status (The legal status is an assumption and is not a legal conclusion. Google has not performed a legal analysis and makes no representation as to the accuracy of the status listed.)
- Pending
Links
- 238000000034 method Methods 0.000 title claims abstract description 221
- 238000012544 monitoring process Methods 0.000 claims abstract description 19
- 238000012545 processing Methods 0.000 claims description 14
- 238000012806 monitoring device Methods 0.000 claims description 13
- 238000004590 computer program Methods 0.000 claims description 12
- 238000012986 modification Methods 0.000 claims description 10
- 230000004048 modification Effects 0.000 claims description 10
- 238000010586 diagram Methods 0.000 description 8
- 238000005516 engineering process Methods 0.000 description 3
- 238000013473 artificial intelligence Methods 0.000 description 2
- 238000004891 communication Methods 0.000 description 2
- 238000012423 maintenance Methods 0.000 description 2
- 238000004422 calculation algorithm Methods 0.000 description 1
- 238000004364 calculation method Methods 0.000 description 1
- 238000010801 machine learning Methods 0.000 description 1
- 230000005055 memory storage Effects 0.000 description 1
- 230000000750 progressive effect Effects 0.000 description 1
- 238000009877 rendering Methods 0.000 description 1
- 230000001052 transient effect Effects 0.000 description 1
Images
Classifications
-
- G—PHYSICS
- G06—COMPUTING; CALCULATING OR COUNTING
- G06F—ELECTRIC DIGITAL DATA PROCESSING
- G06F11/00—Error detection; Error correction; Monitoring
- G06F11/30—Monitoring
- G06F11/3003—Monitoring arrangements specially adapted to the computing system or computing system component being monitored
- G06F11/3017—Monitoring arrangements specially adapted to the computing system or computing system component being monitored where the computing system is implementing multitasking
-
- G—PHYSICS
- G06—COMPUTING; CALCULATING OR COUNTING
- G06F—ELECTRIC DIGITAL DATA PROCESSING
- G06F8/00—Arrangements for software engineering
- G06F8/70—Software maintenance or management
- G06F8/71—Version control; Configuration management
Landscapes
- Engineering & Computer Science (AREA)
- Theoretical Computer Science (AREA)
- General Engineering & Computer Science (AREA)
- Physics & Mathematics (AREA)
- Software Systems (AREA)
- General Physics & Mathematics (AREA)
- Computing Systems (AREA)
- Computer Security & Cryptography (AREA)
- Mathematical Physics (AREA)
- Quality & Reliability (AREA)
- Debugging And Monitoring (AREA)
Abstract
The application discloses a task execution method, a device, equipment and a medium, wherein the method comprises the following steps: when it is monitored that a process is in a finished state in a local task process, determining a next executed target process from the task processes according to the process in the finished state, wherein the task process comprises a plurality of processes, and tasks under the processes are related in service; executing the target process; and monitoring the real-time state of the target process, and updating the task state of the task process according to the real-time state. Therefore, tasks related to business are organized into task flows to be managed, a plurality of related tasks can be managed, operation convenience and execution efficiency of the related tasks are improved, and the related tasks are convenient to maintain.
Description
Technical Field
The application relates to the technical field of Kubernets, in particular to a task execution method, device, equipment and medium.
Background
In the container technology era, a large number of service application scenarios can be obtained through the cloud in the Kubernetes container technology, Kubernetes can create task resources to support the service scenarios, currently, only a single independent task can be managed in the Kubernetes, however, when multiple related tasks are met, the management cannot effectively manage the multiple related tasks, and thus the management performance of the Kubernetes is reduced.
Disclosure of Invention
In view of the above, an object of the present application is to provide a task execution method, device, apparatus, and medium, which can manage a plurality of associated tasks, improve operation convenience and execution efficiency of the associated tasks, and facilitate maintenance of the associated tasks. The specific scheme is as follows:
in a first aspect, the present application discloses a task execution method applied to a kubernets cluster, including:
when it is monitored that a process is in a finished state in a local task process, determining a next executed target process from the task processes according to the process in the finished state, wherein the task process comprises a plurality of processes, and tasks under the processes are related in service;
executing the target process;
and monitoring the real-time state of the target process, and updating the task state of the task process according to the real-time state.
Optionally, before determining a next executed target process from the task processes according to the process in the completed state, the method further includes:
acquiring task configuration information through a locally preset task device;
and creating corresponding bottom layer task resources based on the task configuration information through the task device so as to create tasks corresponding to the task configuration information, wherein the tasks are related in business.
Optionally, the creating, by the task device, a corresponding underlying task resource based on the task configuration information, so as to create a task corresponding to the task configuration information, further includes:
and if the task configuration information exists locally or if the underlying task resource is abnormally established, performing task establishment failure prompt and acquiring new task configuration information.
Optionally, after the task device creates the corresponding underlying task resource based on the task configuration information, the method further includes:
and if a task configuration modification instruction is obtained, modifying the task according to the task configuration modification instruction.
Optionally, after the task device creates the corresponding underlying task resource based on the task configuration information, the method further includes:
acquiring task flow configuration information through a locally preset task management device so as to arrange the task flow according to the task flow configuration information;
and determining tasks corresponding to all the processes in the task processes from the task device according to the task process configuration information.
Optionally, the monitoring the real-time state of the target process includes:
And monitoring the real-time state of the target process through a locally preset monitoring device.
Optionally, after monitoring the real-time state of the target process by using a locally preset monitoring device, the method further includes:
and feeding back the real-time state to the task device and the task management device so that the task device and the task management device can update the corresponding task state respectively.
In a second aspect, the present application discloses a task execution device applied to a kubernets cluster, including:
the system comprises a process determining module, a task processing module and a task processing module, wherein the process determining module is used for determining a next executed target process from task processes according to the processes in a finished state when the process in a local task process is monitored to be in a finished state;
the execution module is used for executing the target process;
the state monitoring module is used for monitoring the real-time state of the target process;
and the state updating module is used for updating the task state of the task flow according to the real-time state.
In a third aspect, the present application discloses an electronic device, comprising:
A memory and a processor;
wherein the memory is used for storing a computer program;
the processor is configured to execute the computer program to implement the task execution method disclosed in the foregoing.
In a fourth aspect, the present application discloses a computer readable storage medium for storing a computer program, wherein the computer program, when executed by a processor, implements the task execution method disclosed in the foregoing.
It can be seen that when it is monitored that a process is in a complete state in a local task process, a next executed target process is determined from the task process according to the process in the complete state, wherein the task process comprises a plurality of processes, tasks in the processes are associated in service, then the target process is executed, a real-time state of the target process needs to be monitored, and the task state of the task process is updated according to the real-time state. Therefore, the method and the device can compile the tasks related to the business into the task flow, when the flow in the task flow is in the completion state, the next executed target flow can be determined from the task flow according to the flow in the completion state, the target flow is executed, the real-time state of the target flow is monitored, and the task state in the task flow is updated, so that the tasks related to the business are compiled into the task flow to be managed, a plurality of related tasks can be managed, the operation convenience and the execution efficiency of the related tasks are improved, and the related tasks are convenient to maintain.
Drawings
In order to more clearly illustrate the embodiments of the present application or the technical solutions in the prior art, the drawings needed to be used in the description of the embodiments or the prior art will be briefly introduced below, it is obvious that the drawings in the following description are only embodiments of the present application, and for those skilled in the art, other drawings can be obtained according to the provided drawings without creative efforts.
FIG. 1 is a flow chart of a task execution method disclosed herein;
FIG. 2 is a flowchart of a specific task execution method disclosed herein;
FIG. 3 is a task creation flow diagram disclosed herein;
FIG. 4 is a task flow creation flow diagram as disclosed herein;
FIG. 5 is a schematic diagram of a task device, a task management device, and a monitoring device according to the present disclosure;
FIG. 6 is a schematic view of a monitoring device according to the present disclosure;
FIG. 7 is a schematic diagram of a task performing device according to the present disclosure;
fig. 8 is a block diagram of an electronic device disclosed in the present application.
Detailed Description
The technical solutions in the embodiments of the present application will be clearly and completely described below with reference to the drawings in the embodiments of the present application, and it is obvious that the described embodiments are only a part of the embodiments of the present application, and not all of the embodiments. All other embodiments, which can be derived by a person skilled in the art from the embodiments given herein without making any creative effort, shall fall within the protection scope of the present application.
At present, a large number of service application scenarios can be cloud-based on a Kubernetes container technology, Kubernetes can create task resources to support these service scenarios, currently, only a single independent task can be managed in Kubernetes, however, when multiple related tasks are met, such management cannot effectively manage the multiple related tasks, and thus, the management performance of the Kubernetes is reduced. In view of this, the present application provides a task execution method, which can manage a plurality of associated tasks, improve operation convenience and execution efficiency of the associated tasks, and facilitate maintenance of the associated tasks.
Referring to fig. 1, an embodiment of the present application discloses a task execution method, which is applied to a kubernets cluster, and the method includes:
step S11: when it is monitored that a process is in a finished state in a local task process, determining a next executed target process from the task processes according to the process in the finished state, wherein the task process comprises a plurality of processes, and tasks under the processes are related in service.
In a specific implementation process, when it is monitored that a process is in a complete state in a local task process, a next executed target process can be determined from the task process according to the process in the complete state, wherein the task process comprises a plurality of processes, that is, the number of processes in the task process is greater than or equal to 2, and the tasks in the processes are related in business. The number of tasks in one process may be 1, or may be multiple, when one process includes multiple tasks, each task in the process is executed in parallel, and after each task in the process is completed, the process is completed.
In practical application, since the execution of the flow needs to be executed according to the sequence in the task flow, when the completion of the flow is monitored, the target flow to be executed next can be determined according to the position of the completed flow in the task flow. For example, the task flow includes flow 1, flow 2, and flow 3, and if flow 2 is currently completed, then flow 3 is to be executed next.
Step S12: and executing the target process.
It is understood that after the target procedure is determined, the target procedure may be performed. Specifically, the task in the target process is executed, that is, the bottom layer task resource corresponding to the task in the target process is called, so as to execute the target process. And if the task under the target flow fails to execute, the task can be executed again.
Step S13: and monitoring the real-time state of the target process, and updating the task state of the task process according to the real-time state.
In the process of executing the target process, a real-time state of the target process needs to be monitored, and a task state in the task process is updated according to the real-time state, specifically, the real-time state of each task in the target process is monitored, so that a task state corresponding to each task in the task process can be known in real time, wherein the task state includes but is not limited to waiting to be executed, being executed and the like. The monitoring of the real-time state of the target process is specifically to monitor the real-time state of each task in the target process.
It can be seen that when it is monitored that a process is in a complete state in a local task process, a next executed target process is determined from the task process according to the process in the complete state, wherein the task process comprises a plurality of processes, tasks in the processes are associated in service, then the target process is executed, a real-time state of the target process needs to be monitored, and the task state of the task process is updated according to the real-time state. Therefore, the method and the device can compile the tasks related to the business into the task flow, when the flow in the task flow is in the completion state, the next executed target flow can be determined from the task flow according to the flow in the completion state, the target flow is executed, the real-time state of the target flow is monitored, and the task state in the task flow is updated, so that the tasks related to the business are compiled into the task flow to be managed, a plurality of related tasks can be managed, the operation convenience and the execution efficiency of the related tasks are improved, and the related tasks are convenient to maintain.
Referring to fig. 2, an embodiment of the present application discloses a specific task execution method, which is applied to a kubernets cluster, and the method includes:
step S21: and acquiring task configuration information through a local preset task device.
In practical application, task configuration information needs to be acquired through a task device preset locally, so that a task is created according to the task configuration information. The task configuration information includes a task name, execution times, a mirror image, and the like. In a specific process, task configuration information corresponding to a plurality of tasks may be acquired at one time, or task configuration information corresponding to only one task may be acquired at one time.
Step S22: and creating corresponding bottom layer task resources based on the task configuration information through the task device so as to create tasks corresponding to the task configuration information, wherein the tasks are related in business.
It can be understood that, after the task configuration information is obtained, the task device may create a corresponding underlying task resource according to the task configuration information to create a task corresponding to the task configuration information, where the tasks have business association with each other. Specifically, the task resource name may be determined according to the task name in the task configuration information, and then the corresponding underlying task resource may be created according to the task resource name. The task resource name has the corresponding relation of the task name, and the task resource name can be determined according to the task name.
In the process of creating the task, if the task configuration information exists locally or if the underlying task resource is abnormally created, a task creation failure prompt is carried out, and new task configuration information is obtained. The task configuration information is locally existed, specifically, whether the task resource name already exists in the namespace selected by the kubernets cluster is judged, if the task resource name already exists in the namespace selected by the kubernets cluster, the task configuration information is locally existed, and if the task resource name does not exist in the namespace selected by the kubernets cluster, the task configuration information is locally absent.
After creating, by the task device, a corresponding underlying task resource based on the task configuration information, further comprising: and if a task configuration modification instruction is obtained, modifying the task according to the task configuration modification instruction. That is, after the task is created, if a task configuration modification instruction is obtained, the task may be modified according to the task configuration modification instruction. For example, after the creation of the task a that needs to be executed 3 times is completed, and after the configuration modification instruction of the task a is acquired, the execution times of the task a is modified to 4 times.
Referring to FIG. 2, a flowchart is created for a task. After entering a task device, acquiring a task configuration instruction, judging whether a task resource name corresponding to a task name in the task configuration information exists in a name space selected by a Kubernetes cluster, if so, acquiring new task configuration information again, if not, creating a bottom layer task resource corresponding to the task name, judging whether the bottom layer task resource is created successfully, if so, ending, and if not, acquiring new task configuration information again.
Step S23: and acquiring task flow configuration information through a locally preset task management device so as to arrange the task flow according to the task flow configuration information.
After the task is created, task flow configuration information needs to be acquired through a locally preset task management device, so that the task flow is arranged according to the task flow configuration information. The task flow configuration information includes a task flow name, a task flow execution frequency, a flow included in the task flow, a task name to be executed under each flow, and the like, the task name to be executed under each flow is a name of a task created in the task device, and the task flow execution frequency is the number of times that the whole task flow needs to be executed.
In the process of arranging the task flow according to the task flow configuration information, it is also required to determine whether the name of the task management resource corresponding to the task flow name already exists in the namespace selected by the kubernets cluster, if so, new task flow configuration information is acquired again, and if not, the task flow is arranged according to the task flow configuration information.
Correspondingly, after the current task flow arrangement is finished, the task flow can be changed according to the obtained task flow configuration modification instruction.
Step S24: and determining tasks corresponding to all the processes in the task processes from the task device according to the task process configuration information.
It can be understood that after the task flow configuration information is obtained, the task corresponding to each flow in the task flow can be determined from the task device according to the task name in the task flow configuration information. The number of tasks to be executed in one flow may be 2 or more. For example, if a task name to be executed is task 1 under flow 1 in the task flow, the task 1 in the task device is determined as a task to be executed under flow 1 in the task flow. After the task corresponding to each process in the task flows is determined from the task device according to the task flow configuration information, the method further includes: and creating the task management resources corresponding to the task flow layer according to the task management resource names.
Referring to FIG. 4, a flow chart is created for a task flow. After entering a task management device, acquiring task flow configuration information, judging whether a name of a task management resource corresponding to the task flow configuration information exists in a name space selected by a Kubernetes cluster, if so, acquiring new task flow configuration information again, if not, arranging a task flow according to the task flow configuration information, creating a corresponding bottom layer task management resource, judging whether the bottom layer task management resource is created successfully, if so, finishing the creation, and if not, acquiring new task flow configuration information.
Step S25: when it is monitored that a process is in a completion state in the task processes, determining a next executed target process from the task processes according to the process in the completion state, wherein the task processes comprise a plurality of processes, and tasks under the processes are related in service.
Step S26: and executing the target process.
Step S27: and monitoring the real-time state of the target process, and updating the task state of the task process according to the real-time state.
In the process of executing the target process, the real-time state of the target process needs to be monitored, and the task state of the task process needs to be updated according to the real-time state. Specifically, the real-time state of the target process is monitored through a locally preset monitoring device. After monitoring the real-time state of the target process through a locally preset monitoring device, the method further comprises the following steps: and feeding back the real-time state to the task device and the task management device so that the task device and the task management device can update the corresponding task state respectively.
When a task flow starts to execute, the acquired execution instruction may be used as a trigger signal to start to execute a task corresponding to a first flow, and a condition for executing a second flow is that the first flow is completed until a last flow in the task flows is successfully executed.
Fig. 5 is a schematic structural diagram of the task device, the task management device, and the monitoring device. The task device acquires the task configuration information and then creates a plurality of tasks with relevance in business, such as task 1, task 2, task 3, task N and the like, the task management device acquires the task flow configuration information and then creates a task flow, the whole task flow comprises flow 1, flow 2, flow 3, flow N and the like, the task 1 needing to be executed is arranged under the flow 1, the task 2 and the task 3 needing to be executed are arranged under the flow 2, and the task 3 needing to be executed is arranged under the flow 3. The monitoring device monitors the task state change of the task device and synchronizes the task management device and the task state in the task device according to the task state.
Fig. 6 is a schematic diagram of the monitoring device. The task device in the service end is used for creating, updating and executing tasks, the task management device is used for creating, updating and executing task flows, and particularly, connecting a control manager in the cluster management end through an application layer interface to create, update and execute the resources corresponding to the task or the task flow, wherein after the control manager creates the task or the task flow, starting to carry out monitoring operation through the api server, storing the resource data to the etcd by the api server, returning the event information of the operation by the etcd, processing the event information by the api server, and sending the processing event information to a control manager, uploading the resource state to an application interface layer by the control manager according to the processing event information, uploading the resource state to a monitoring device by the application interface layer, and updating the resource states in the task device and the task management device by the monitoring device according to the resource states, wherein the resource states are also the task states.
Referring to fig. 7, an embodiment of the present application discloses a task execution device applied to a kubernets cluster, including:
the task flow determining module 11 is configured to determine, when it is monitored that a flow is in a complete state in a local task flow, a next executed target flow from the task flow according to the flow in the complete state, where the task flow includes multiple flows, and tasks under the flows are related in business;
An execution module 12, configured to execute the target process;
a state monitoring module 13, configured to monitor a real-time state of the target process;
and the state updating module 14 is configured to update the task state of the task flow according to the real-time state.
It can be seen that when it is monitored that a process is in a complete state in a local task process, a next executed target process is determined from the task process according to the process in the complete state, wherein the task process comprises a plurality of processes, tasks in the processes are associated in service, then the target process is executed, a real-time state of the target process needs to be monitored, and the task state of the task process is updated according to the real-time state. Therefore, the method and the device can compile the tasks related to the business into the task flow, when the flow in the task flow is in the completion state, the next executed target flow can be determined from the task flow according to the flow in the completion state, the target flow is executed, the real-time state of the target flow is monitored, and the task state in the task flow is updated, so that the tasks related to the business are compiled into the task flow to be managed, a plurality of related tasks can be managed, the operation convenience and the execution efficiency of the related tasks are improved, and the related tasks are convenient to maintain.
Referring to fig. 8, a schematic structural diagram of an electronic device 20 provided in an embodiment of the present application is shown, where the electronic device 20 may implement the steps of the task execution method disclosed in the foregoing embodiment.
In general, the electronic device 20 in the present embodiment includes: a processor 21 and a memory 22.
The processor 21 may include one or more processing cores, such as a four-core processor, an eight-core processor, and so on. The processor 21 may be implemented by at least one hardware of a DSP (digital signal processing), an FPGA (field-programmable gate array), and a PLA (programmable logic array). The processor 21 may also include a main processor and a coprocessor, where the main processor is a processor for processing data in an awake state, and is also called a Central Processing Unit (CPU); a coprocessor is a low power processor for processing data in a standby state. In some embodiments, the processor 21 may be integrated with a GPU (graphics processing unit) which is responsible for rendering and drawing images to be displayed on the display screen. In some embodiments, the processor 21 may include an AI (artificial intelligence) processor for processing a calculation operation related to machine learning.
Memory 22 may include one or more computer-readable storage media, which may be non-transitory. Memory 22 may also include high speed random access memory, as well as non-volatile memory, such as one or more magnetic disk storage devices, flash memory storage devices. In this embodiment, the memory 22 is at least used for storing the following computer program 221, wherein after being loaded and executed by the processor 21, the computer program can realize the steps of the task execution method disclosed in any of the foregoing embodiments. In addition, the resources stored in the memory 22 may also include an operating system 222, data 223, and the like, and the storage manner may be a transient storage or a permanent storage. The operating system 222 may be Windows, Unix, Linux, or the like. Data 223 may include a wide variety of data.
In some embodiments, the electronic device 20 may further include a display 23, an input/output interface 24, a communication interface 25, a sensor 26, a power supply 27, and a communication bus 28.
Those skilled in the art will appreciate that the configuration shown in fig. 8 is not limiting to electronic device 20 and may include more or fewer components than those shown.
Further, the present application also discloses a computer readable storage medium for storing a computer program, wherein the computer program is used for implementing the task execution method disclosed in any of the foregoing embodiments when being executed by a processor.
For the specific process of the task execution method, reference may be made to corresponding contents disclosed in the foregoing embodiments, and details are not described here.
The embodiments are described in a progressive manner, each embodiment focuses on differences from other embodiments, and the same or similar parts among the embodiments are referred to each other. The device disclosed by the embodiment corresponds to the method disclosed by the embodiment, so that the description is simple, and the relevant points can be referred to the method part for description.
The steps of a method or algorithm described in connection with the embodiments disclosed herein may be embodied directly in hardware, in a software module executed by a processor, or in a combination of the two. A software module may reside in Random Access Memory (RAM), memory, Read Only Memory (ROM), electrically programmable ROM, electrically erasable programmable ROM, registers, hard disk, a removable disk, a CD-ROM, or any other form of storage medium known in the art.
Finally, it is further noted that, herein, relational terms such as first and second, and the like may be used solely to distinguish one entity or action from another entity or action without necessarily requiring or implying any actual such relationship or order between such entities or actions. Also, the terms "comprises," "comprising," or any other variation thereof, are intended to cover a non-exclusive inclusion, such that a process, method, article, or apparatus that comprises a list of other elements does not include only those elements but may include other elements not expressly listed or inherent to such process, method, article, or apparatus. Without further limitation, an element defined by the phrase "comprising an … …" does not exclude the presence of other identical elements in a process, method, article, or apparatus that comprises the element.
The above detailed description is provided for a method, an apparatus, a device, and a medium for task execution, and a specific example is applied in the present disclosure to explain the principle and the implementation of the present disclosure, and the description of the above embodiment is only used to help understand the method and the core idea of the present disclosure; meanwhile, for a person skilled in the art, according to the idea of the present application, there may be variations in the specific embodiments and the application scope, and in summary, the content of the present specification should not be construed as a limitation to the present application.
Claims (10)
1. A task execution method is applied to a Kubernets cluster and comprises the following steps:
when it is monitored that a process is in a finished state in a local task process, determining a next executed target process from the task processes according to the process in the finished state, wherein the task process comprises a plurality of processes, and tasks under the processes are related in service;
executing the target process;
and monitoring the real-time state of the target process, and updating the task state of the task process according to the real-time state.
2. The task execution method according to claim 1, wherein before determining a next target process to be executed from the task processes according to the process in the completed state, the method further comprises:
acquiring task configuration information through a locally preset task device;
and creating corresponding bottom layer task resources based on the task configuration information through the task device so as to create tasks corresponding to the task configuration information, wherein the tasks are related in business.
3. The task execution method according to claim 2, wherein, in creating, by the task device, the corresponding underlying task resource based on the task configuration information, so as to create the task corresponding to the task configuration information, the method further includes:
And if the task configuration information exists locally or if the underlying task resource is abnormally established, performing task establishment failure prompt and acquiring new task configuration information.
4. The task execution method of claim 2, wherein after creating, by the task device, the corresponding underlying task resource based on the task configuration information, further comprising:
and if a task configuration modification instruction is obtained, modifying the task according to the task configuration modification instruction.
5. The task execution method of claim 2, wherein after creating, by the task device, the corresponding underlying task resource based on the task configuration information, further comprising:
acquiring task flow configuration information through a locally preset task management device so as to arrange the task flow according to the task flow configuration information;
and determining tasks corresponding to all the processes in the task processes from the task device according to the task process configuration information.
6. The task execution method of claim 5, wherein the monitoring the real-time status of the target process comprises:
And monitoring the real-time state of the target process through a locally preset monitoring device.
7. The task execution method according to claim 6, wherein after monitoring the real-time status of the target process by a locally preset monitoring device, the method further comprises:
and feeding back the real-time state to the task device and the task management device so that the task device and the task management device can update the corresponding task state respectively.
8. A task execution apparatus, applied to a kubernets cluster, comprising:
the system comprises a process determining module, a task processing module and a task processing module, wherein the process determining module is used for determining a next executed target process from task processes according to the processes in a finished state when the process in a local task process is monitored to be in a finished state;
the execution module is used for executing the target process;
the state monitoring module is used for monitoring the real-time state of the target process;
and the state updating module is used for updating the task state of the task flow according to the real-time state.
9. An electronic device, comprising:
a memory and a processor;
wherein the memory is used for storing a computer program;
the processor is configured to execute the computer program to implement the task execution method according to any one of claims 1 to 7.
10. A computer-readable storage medium for storing a computer program, wherein the computer program, when executed by a processor, implements a task execution method according to any one of claims 1 to 7.
Priority Applications (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN202010567664.1A CN111858234A (en) | 2020-06-19 | 2020-06-19 | Task execution method, device, equipment and medium |
Applications Claiming Priority (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN202010567664.1A CN111858234A (en) | 2020-06-19 | 2020-06-19 | Task execution method, device, equipment and medium |
Publications (1)
| Publication Number | Publication Date |
|---|---|
| CN111858234A true CN111858234A (en) | 2020-10-30 |
Family
ID=72986983
Family Applications (1)
| Application Number | Title | Priority Date | Filing Date |
|---|---|---|---|
| CN202010567664.1A Pending CN111858234A (en) | 2020-06-19 | 2020-06-19 | Task execution method, device, equipment and medium |
Country Status (1)
| Country | Link |
|---|---|
| CN (1) | CN111858234A (en) |
Cited By (1)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN112597166A (en) * | 2020-12-28 | 2021-04-02 | 恩亿科(北京)数据科技有限公司 | Data stream task management method, system, computer device and readable storage medium |
Citations (3)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| WO2017101488A1 (en) * | 2015-12-18 | 2017-06-22 | 乐视控股（北京）有限公司 | Real-time transcoding monitoring method and real-time transcoding system |
| CN109697118A (en) * | 2017-10-20 | 2019-04-30 | 北京京东尚科信息技术有限公司 | Streaming computing task management method, device, electronic equipment and storage medium |
| CN110888722A (en) * | 2019-11-15 | 2020-03-17 | 北京奇艺世纪科技有限公司 | Task processing method and device, electronic equipment and computer readable storage medium |
-
2020
- 2020-06-19 CN CN202010567664.1A patent/CN111858234A/en active Pending
Patent Citations (3)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| WO2017101488A1 (en) * | 2015-12-18 | 2017-06-22 | 乐视控股（北京）有限公司 | Real-time transcoding monitoring method and real-time transcoding system |
| CN109697118A (en) * | 2017-10-20 | 2019-04-30 | 北京京东尚科信息技术有限公司 | Streaming computing task management method, device, electronic equipment and storage medium |
| CN110888722A (en) * | 2019-11-15 | 2020-03-17 | 北京奇艺世纪科技有限公司 | Task processing method and device, electronic equipment and computer readable storage medium |
Non-Patent Citations (1)
| Title |
|---|
| 方泽杭等: "云环境下以Artifact为中心的业务过程管理", 《东华大学学报(自然科学版)》 * |
Cited By (1)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN112597166A (en) * | 2020-12-28 | 2021-04-02 | 恩亿科(北京)数据科技有限公司 | Data stream task management method, system, computer device and readable storage medium |
Similar Documents
| Publication | Publication Date | Title |
|---|---|---|
| US8918783B2 (en) | Managing virtual computers simultaneously with static and dynamic dependencies | |
| JP6011479B2 (en) | Application management apparatus, application management system, and program | |
| CN105007323A (en) | System and method for arranging cloud resources | |
| CN107291481B (en) | Component updating method, device and system | |
| US11354150B1 (en) | Utilizing maintenance event windows to determine placement of instances | |
| CN113377665B (en) | Container technology-based testing method and device, electronic equipment and storage medium | |
| CN115686805A (en) | GPU resource sharing method and device, and GPU resource sharing scheduling method and device | |
| CN111858234A (en) | Task execution method, device, equipment and medium | |
| CN118331603A (en) | Application extension method, computing device and device cluster | |
| US20220229689A1 (en) | Virtualization platform control device, virtualization platform control method, and virtualization platform control program | |
| CN114610446B (en) | Method, device and system for automatically injecting probe | |
| CN116627437A (en) | Deployment method and device of Airflow service, storage medium and computer equipment | |
| CN115390992A (en) | Virtual machine creating method, device, equipment and storage medium | |
| US11836523B2 (en) | Introspection of a containerized application in a runtime environment | |
| CN114936070A (en) | Service rolling release method, device and medium based on container cluster scheduling technology | |
| CN114553859A (en) | BMC configuration management method and device, electronic equipment and storage medium | |
| CN113608754A (en) | Service instantiation method and device and electronic equipment | |
| CN113326052A (en) | Method and device for upgrading service component, computer equipment and storage medium | |
| JP5317182B2 (en) | POS terminal, module update method and module update program | |
| WO2019187975A1 (en) | System update device and system update method | |
| CN111414232A (en) | Method and device for processing template data of virtual machine | |
| CN115222041B (en) | Graph generation method and device for model training, electronic equipment and storage medium | |
| US11977922B2 (en) | Resource reuse for pipeline workloads | |
| EP4227796A1 (en) | Service deployment processing method and apparatus, electronic device, and storage medium | |
| US11941432B2 (en) | Processing system, processing method, higher-level system, lower-level system, higher-level program, and lower-level program |
Legal Events
| Date | Code | Title | Description |
|---|---|---|---|
| PB01 | Publication | ||
| PB01 | Publication | ||
| SE01 | Entry into force of request for substantive examination | ||
| SE01 | Entry into force of request for substantive examination | ||
| RJ01 | Rejection of invention patent application after publication | ||
| RJ01 | Rejection of invention patent application after publication |
Application publication date: 20201030 |