IP Library › Granted Patent US 11,403,152
Granted Patent B2
US 11,403,152 · App. 16/562,266 · Granted Aug 2, 2022

Task orchestration method and system

Inventor: Haodong Chen (Beijing, CN)
Assignee: Beijing Baidu Netcom Science and Technology Co., Ltd.
G06F9/5088G06F9/455G06F9/45533G06F9/45558G06F9/48G06F9/4806G06F9/4843G06F9/4856G06F9/4862G06F9/4868G06F9/4881G06F9/50G06F9/5005G06F9/5027G06F9/5061G06F9/5072G06F9/5083G06F2009/4557G06F2009/45562G06F2009/45575G06F2009/45583
View Patent ↗
Loading inventors, assignments & file history…
Monitor This Case
Get email alerts when status or documents change.
Order Certified Copies
Most orders are placed with the USPTO same day — all within 24 business hours.
Order via The Patent Place →
Pre-filled with this patent's details
Quick Facts
Patent No.
US 11,403,152
App. No.
16/562,266
Granted
Aug 2, 2022
Kind
B2
Abstract

Embodiments of the disclosure provide a method and system for task orchestration. A method may include: providing, by a task master control unit, an execution instruction of a task related to a module in an application container to a node agent service unit in an auxiliary application container bound to the application container, the auxiliary application container sharing a file system with the application container; and executing, by the node agent service unit, a command for completing the task, in response to acquiring the execution instruction of the task.

Claims (60)

1. A method for task orchestration, comprising:

providing, by a task master control unit, an execution instruction of a task related to a module in an application container to a node agent service unit in an auxiliary application container bound to the application container, the auxiliary application container sharing a file system with the application container, wherein a granularity of the module is smaller than that of the application container;

executing, by the node agent service unit, a command for completing the task, in response to acquiring the execution instruction of the task;

receiving a data packet making instruction sent by the task master control unit using a data packet making unit;

making a task-related data packet meeting a preset criterion; and

sending the task-related data packet meeting the preset criterion to an object storage system.

2. The method according to claim 1 , wherein the method further comprises:

storing task execution status information using a state storing unit, the task execution status information comprising: a task execution result, and version information of the module in the application container after executing the task.

3. The method according to claim 2 , wherein the method further comprises:

acquiring the task execution status information of the task from the state storing unit using a state asynchronous calibration unit;

detecting whether there is a situation requiring task compensation based on the acquired task execution status information; and

sending a task compensation instruction of the task to the task master control unit, in response to detecting there being the situation requiring task compensation.

4. The method according to claim 3 , wherein the method further comprises:

sending an instruction of a preset type to a unit associated with the instruction of the preset type using a message bus unit, the instruction of the preset type comprising one of following items: an execution instruction, the data packet making instruction, or the task compensation instruction.

5. The method according to claim 4 , wherein the task is a deployment task; and the method further comprises:

sending, by the task master control unit, a deployment data packet making instruction to the data packet making unit; receiving, by the task master control unit, a packing result indicating completing making a deployment task-related data packet meeting the preset criterion sent by the data packet making unit, wherein the deployment task-related data packet meeting the preset criterion is stored in the object storage system; and providing, by the task master control unit, an execution instruction of the deployment task to the node agent service unit; and

pulling, by the node agent service unit, the deployment task-related data packet meeting the preset criterion from the object storage system, in response to acquiring the execution instruction of the deployment task; executing, by the node agent service unit, a command for completing the deployment task, to obtain an execution result of the deployment task; and synchronizing the execution result of the deployment task and the version information of the module to the state storing unit.

6. The method according to claim 4 , wherein the task is a timed task; and the method further comprises:

sending, by the task master control unit, an execution instruction of the timed task to the node agent service unit at intervals of a preset duration, wherein the node agent service unit, in response to acquiring the execution instruction of the timed task, executes a command for completing the timed task, to obtain an execution result of the timed task, and synchronizes the execution result of the timed task and the version information of the module to the state storing unit.

7. The method according to claim 4 , wherein the task is a data delivery task; and the method further comprises:

sending, by the task master control unit, a delivery data packet making instruction to the data packet making unit;

receiving, by the task master control unit, a packing result indicating completing making a delivery data packet meeting the preset criterion sent by the data packet making unit, wherein the delivery data packet meeting the preset criterion is stored in the object storage system; and sending, by the task master control unit, an execution instruction of the data delivery task to the node agent service unit; and

pulling, by the node agent service unit, the delivery data packet meeting the preset criterion from the object storage system, in response to acquiring the execution instruction of the data delivery task; decompressing, by the node agent service unit, the delivery data packet, and delivering, by the node agent service unit, decompressed data to a target directory in the application container, to obtain an execution result of the data delivery task; and synchronizing, by the node agent service unit, the execution result of the data delivery task to the state storing unit.

8. A non-transitory computer readable medium, storing a computer program thereon, wherein the computer program, when executed by a processor, implements the method according to claim 1 .

9. A system for task orchestration, comprising:

at least one processor; and

a memory that is communicated with at least one processor wherein, the memory stores instructions executable by the at least one processor to:

provide an execution instruction of a task related to a module in an application container to a node agent service unit in an auxiliary application container bound to the application container, the auxiliary application container sharing a file system with the application container, wherein a granularity of the module is smaller than that of the application container;

execute a command for completing the task, in response to acquiring the execution instruction of the task;

receive a data packet making instruction sent by a task master control unit using a data packet making unit;

make a task-related data packet meeting a preset criterion; and

send the task-related data packet meeting the preset criterion to an object storage system.

10. The system according to claim 9 , wherein the processor is further configured to execute the instructions to:

store task execution status information, the task execution status information comprising:

a task execution result, and

version information of the module in the application container after executing the task.

11. The system according to claim 10 , wherein the processor is further configured to execute the instructions to:

acquire the task execution status information of the task from a state storing unit;

detect whether there is a situation requiring task compensation based on the acquired task execution status information; and

send a task compensation instruction of the task to the task master control unit, in response to detecting there being the situation requiring task compensation.

12. The system according to claim 11 , wherein the processor is further configured to execute the instructions to:

send an instruction of a preset type to a unit associated with the instruction of the preset type, the instruction of the preset type comprising one of following items: an execution instruction, the data packet making instruction, or the task compensation instruction.

13. The system according to claim 12 , wherein the task is a deployment task; and the processor is further configured to execute the instructions to:

send a deployment data packet making instruction to the data packet making unit;

receive a packing result indicating completing making a deployment task-related data packet meeting the preset criterion sent by the data packet making unit, wherein the deployment task-related data packet meeting the preset criterion is stored in the object storage system; and

provide an execution instruction of the deployment task to the node agent service unit; and

have the node agent service unit-pull the deployment task-related data packet meeting the preset criterion from the object storage system, in response to acquiring the execution instruction of the deployment task;

execute a command for completing the deployment task, to obtain an execution result of the deployment task; and

synchronize the execution result of the deployment task and the version information of the module to the state storing unit.

14. The system according to claim 12 , wherein the task is a timed task; and the processor is further configured to execute the instructions to: send an execution instruction of the timed task to the node agent service unit at intervals of a preset duration,

wherein the node agent service unit is configured to:

in response to acquiring the execution instruction of the timed task, execute a command for completing the timed task, to obtain an execution result of the timed task, and

synchronize the execution result of the timed task and the version information of the module to the state storing unit.

15. The system according to claim 12 , wherein the task is a data delivery task; and the processor is further configured to execute the instructions to:

send a delivery data packet making instruction to a data packet making unit;

receive a packing result indicating completing making a delivery data packet meeting the preset criterion sent by the data packet making unit, wherein the delivery data packet meeting the preset criterion is stored in the object storage system; and

send an execution instruction of the data delivery task to the node agent service unit; and

have the node agent service unit pull the delivery data packet meeting the preset criterion from the object storage system, in response to acquiring the execution instruction of the data delivery task;

deliver the delivery data packet to a target directory in the application container, to obtain an execution result of the data delivery task; and

synchronize the execution result of the data delivery task to the state storing unit.

Assignments (1)
ASSIGNMENT OF ASSIGNOR'S INTEREST Recorded Sep 5, 2019
From: CHEN, HAODONG
To: BEIJING BAIDU NETCOM SCIENCE AND TECHNOLOGY CO., LTD.
Reel/Frame 050287/0505 →
Priority Claims (1)
CN 201811312691.3 · Nov 6, 2018 · national
Continuity (1)
Related Publication 20190391844A1 · Dec 26, 2019