RESOURCE SCHEDULING SYSTEM AND METHOD
Embodiments of the present specification provide a resource scheduling system and method, where a task processor receives a task processing request submitted for a task to be processed, and creates, based on the task processing request, a resource acquiring request and send same to a scheduler; a resource processing node receives the task processing request, and creates, based on the task processing request, schedulable resource information and sends same to the scheduler; the scheduler executes, according to the resource acquiring request and the schedulable resource information, resource scheduling on the task to be processed, to obtain a resource scheduling result, and sends the resource scheduling result to the resource processing node and the task processor. The resource acquiring request and the schedulable resource information are respectively sent by the task processor and the resource processing node to the scheduler directly.
1 . A resource scheduling system, comprising:
a scheduler and a task manager, wherein the task manager comprises a task processor and a resource processing node;
the task processor is configured to: receive a task processing request submitted for a task to be processed; and create, based on the task processing request, a resource acquiring request and send the resource acquiring request to the scheduler;
the resource processing node is configured to: receive the task processing request; and create, based on the task processing request, schedulable resource information and send the schedulable resource information to the scheduler;
the scheduler is configured to execute, according to the resource acquiring request and the schedulable resource information, resource scheduling on the task to be processed, to obtain a resource scheduling result; and send the resource scheduling result to the resource processing node and the task processor.
2 . The resource scheduling system according to claim 1 , wherein the scheduler is further configured to, under a situation where the scheduler is at a malfunction recovery state: create, according to the malfunction recovery state, an information acquiring request; send the information acquiring request to the resource processing node and the task processor;
the scheduler is further configured to, under a situation of receiving malfunction recovery information associated with the information acquiring request, execute malfunction recovery processing based on the malfunction recovery information;
the scheduler is further configured to, under a situation of not receiving the malfunction recovery information, send the resource scheduling result to the resource processing node and the task processor.
3 . The resource scheduling system according to claim 2 , wherein the scheduler is further configured to: under a situation of receiving the malfunction recovery information fed back by the resource processing node, determine a target resource scheduling result according to the malfunction recovery information, and send the target resource scheduling result to the task processor and the resource processing node; or,
under a situation of receiving the malfunction recovery information fed back by the task processor, send scheduling result cancel information to the task processor.
4 . The resource scheduling system according to claim 2 , wherein the scheduler is further configured to: determine whether the malfunction recovery information is received within a preset time interval;
if yes, perform the step of executing the malfunction recovery processing based on the malfunction recovery information;
if no, send the resource result cancel information to the resource processing node and the task processor.
5 . The resource scheduling system according to claim 1 , wherein the task processor is further configured to: receive the resource scheduling result, and send, based on the resource scheduling result, the task to be processed to the resource processing node;
the resource processing node is further configured to: receive the resource scheduling result and the task to be processed, determine, according to the resource scheduling result, a target resource corresponding to the task to be processed, and use the target resource to execute the task to be processed.
6 . The resource scheduling system according to claim 5 , wherein the task processor is further configured to, under a situation of monitoring that an execution of the task to be processed is completed, send task execution completed information corresponding to the task to be processed to the scheduler;
the scheduler is further configured to: create, based on the task execution completed information, a resource release request, and send the resource release request to the resource processing node;
the resource processing node is further configured to: receive the resource release request, and release the target resource according to the resource release request.
7 . An information processing method, applied in the resource scheduling system according to claim 1 , comprising:
determining, by a task manager, service information in response to a service request, and reading an initial transmission parameter; updating, based on the service information, the initial transmission parameter to a target transmission parameter; and sending the service information and the target transmission parameter to a scheduler, and storing them to a transmission information queue;
determining, by the scheduler, feedback information according to the service information and the target transmission parameter under a situation of receiving the service information and the target transmission parameter, and reading an initial receiving parameter; and updating, based on the feedback information, the initial receiving parameter to a target receiving parameter, and sending the feedback information and the target receiving parameter to the task manager; and
receiving, by the task manager, the feedback information and the target receiving parameter; updating, based on the target receiving parameter, a state parameter corresponding to the service information and the target transmission parameter, and updating the transmission information queue according to the updated state parameter.
8 . The information processing method according to claim 7 , wherein the updating, based on the feedback information, the initial receiving parameter to the target receiving parameter comprises: updating, the initial receiving parameter to an intermediate receiving parameter; and updating, based on the feedback information, the intermediate receiving parameter to the target receiving parameter.
9 . The information processing method according to claim 8 , comprising: updating, based on the service information, a transmission information parameter contained in the initial transmission parameter, to obtain the target transmission parameter;
the updating, based on the feedback information, the intermediate receiving parameter to the target receiving parameter comprises: updating, according to a transmission information parameter contained in the target transmission parameter, a first confirmation parameter contained in the initial receiving parameter, to obtain the intermediate receiving parameter.
10 . The information processing method according to claim 9 , comprising: updating, by the scheduler, a receiving information parameter contained in the intermediate receiving parameter according to the feedback information and the intermediate receiving parameter, to obtain the target receiving parameter.
11 . The information processing method according to claim 10 , comprising: wherein
under a situation of receiving the target receiving parameter, updating, by the task manager, a second confirmation parameter contained in the target transmission parameter and the state parameter based on the receiving information parameter contained in the target receiving parameter; and
deleting, based on the updated state parameter, the service information and the target transmission parameter stored in the transmission information queue.
12 . The information processing method according to claim 7 , comprising: under a situation of not receiving the feedback information, ending, by the task manager, the service information and the target transmission parameter stored in the transmission information queue to the scheduler according to a preset information transmission rule.
13 . A resource scheduling method, comprising:
receiving, by a task processor, a task processing request submitted for a task to be processed; and creating, based on the task processing request, a resource acquiring request and sending the resource acquiring request to a scheduler;
receiving, by a resource processing node, the task processing request; and creating, based on the task processing request, schedulable resource information and sending the schedulable resource information to the scheduler; and
executing, by the scheduler according to the resource acquiring request and the schedulable resource information, resource scheduling on the task to be processed, to obtain a resource scheduling result; and sending the resource scheduling result to the resource processing node and the task processor.
14 . A computing device, comprising:
a memory and a processor;
wherein the memory is configured to store computer executable instructions, the processor is configured to execute the computer executable instructions, when the computer executable instructions are executed by the processor, steps of the method according to claim 7 are implemented.
15 . A computer readable storage medium, storing computer executable instructions, wherein when the computer executable instructions are executed by a processor, steps of the method according to claim 7 are implemented.
16 . The resource scheduling method according to claim 13 , comprising:
under a situation where the scheduler is at a malfunction recovery state, creating, by the scheduler, an information acquiring request according to the malfunction recovery state; sending the information acquiring request to the resource processing node and the task processor;
under a situation of receiving malfunction recovery information associated with the information acquiring request, executing, by the scheduler, malfunction recovery processing based on the malfunction recovery information; and
under a situation of not receiving the malfunction recovery information, sending, by the scheduler, the resource scheduling result to the resource processing node and the task processor.
17 . The resource scheduling method according to claim 16 , comprising:
under a situation of receiving the malfunction recovery information fed back by the resource processing node, determining, by the scheduler, a target resource scheduling result according to the malfunction recovery information, and sending the target resource scheduling result to the task processor and the resource processing node; or
under a situation of receiving the malfunction recovery information fed back by a task manager, sending, by the scheduler, scheduling result cancel information to the task manager.
18 . The resource scheduling method according to claim 16 , comprising:
determining, by the scheduler, whether the malfunction recovery information is received within a preset time interval;
if yes, performing the step of executing the malfunction recovery processing based on the malfunction recovery information;
if no, sending the resource result cancel information to the resource processing node and the task processor.
19 . The resource scheduling method according to claim 13 , comprising:
receiving, by the task processor, the resource scheduling result, and sending, based on the resource scheduling result, the task to be processed to the resource processing node; receiving, by the resource processing node, the resource scheduling result and the task to be processed, determining, according to the resource scheduling result, a target resource corresponding to the task to be processed, and using the target resource to execute the task to be processed.
20 . A computer readable storage medium, storing computer executable instructions, wherein when the computer executable instructions are executed by a processor, following steps are implemented:
receiving, by a task processor, a task processing request submitted for a task to be processed;
and creating, based on the task processing request, a resource acquiring request and sending the resource acquiring request to a scheduler;
receiving, by a resource processing node, the task processing request; and creating, based on the task processing request, schedulable resource information and sending the schedulable resource information to the scheduler; and
executing, by the scheduler according to the resource acquiring request and the schedulable resource information, resource scheduling on the task to be processed, to obtain a resource scheduling result; and sending the resource scheduling result to the resource processing node and the task processor.