Method and apparatus for processing gateway device fault
The present invention provides methods and apparatuses for processing a gateway device fault. According to one embodiment, when a fault on a gateway device is detected, computing tasks currently executed by the faulty gateway device are acquired; to-be-allocated computing tasks are screened out according to parameters configured when the computing tasks are issued; the computing tasks running on the faulty gateway device are terminated, and the to-be-allocated computing tasks are scheduled to other gateway devices in a normal state according to a preset scheduling strategy. Further, task states of the to-be-allocated computing tasks are recovered, and the to-be-allocated computing tasks are executed by the other gateway devices. Embodiments of the present application can help avoid the problem that computing tasks fail due to a fault occurring in the gateway device, thereby the overall execution efficiency of the computing tasks and ensuring system stability.
1. A method for processing a gateway device fault, comprising:
monitoring temporary files registered by a plurality of gateway devices during boot-up;
in response to a temporary file of the temporary files having been deleted, identifying, among the plurality of gateway devices, a gateway device corresponding to the deleted temporary file;
acquiring computing tasks being executed by the identified gateway device;
identifying to-be-allocated computing tasks among the acquired computing tasks according to parameters configured when the computing tasks are issued, the parameters indicating whether the computing tasks require failover processing;
scheduling the to-be-allocated computing tasks to one or more other gateway devices; and
recovering task states of the to-be-allocated computing tasks to enable executing each of the to-be-allocated computing tasks by the one or more other gateway devices based on the task state of each to-be-allocated computing task.
2. The method of claim 1 , further comprising:
terminating the computing tasks on the gateway device after the fault is detected.
3. The method of claim 2 , wherein terminating the computing tasks on the gateway device further comprises:
in response to a fault type of the gateway device being network disconnection, traversing processes of the gateway device and terminating resident processes of the gateway device; or
in response to a fault type of the gateway device being process crash, terminating resident processes started by the gateway device.
4. The method of claim 1 , wherein scheduling the to-be-allocated computing tasks to one or more other gateway devices comprises:
scheduling the to-be-allocated computing tasks to the one or more other gateway devices according to a preset scheduling strategy.
5. A method for processing a gateway device fault, comprising:
acquiring computing tasks being executed by a gateway device in response to a fault on the gateway device has been detected;
identifying to-be-allocated computing tasks among the acquired computing tasks according to parameters configured when the computing tasks are issued, the parameters indicating whether the computing tasks require failover processing by at least one of:
determining whether a failover processing value of a parameter corresponding to a computing task is in a valid state;
placing the computing task into a queue as a to-be-allocated computing task in response to the failover processing value being in the valid state; or
setting the computing task to an error state in response to the failover processing value being in an invalid state; and
recovering task states of the to-be-allocated computing tasks to enable executing each of the to-be-allocated computing tasks by the one or more other gateway devices based on the task state of each to-be-allocated computing task.
6. A method for processing a gateway device fault, comprising:
acquiring computing tasks being executed by a gateway device in response to a fault on the gateway device has been detected;
identifying to-be-allocated computing tasks among the acquired computing tasks according to parameters configured when the computing tasks are issued, the parameters indicating whether the computing tasks require failover processing;
scheduling the to-be-allocated computing tasks to one or more other gateway devices; and
recovering task states of the to-be-allocated computing tasks to enable executing each of the to-be-allocated computing tasks by the one or more other gateway devices based on the task state of each to-be-allocated computing task, by at least one of the following:
querying task states of the to-be-allocated computing tasks; and
in response to at least some of the to-be-allocated computing tasks running, acquiring task states and logs of the at least some of the to-be-allocated computing tasks that are running;
in response to at least some of the to-be-allocated computing tasks failing to run, resubmitting the at least some of the to-be-allocated computing tasks that had failed to run and acquiring task states and logs of the at least some of the to-be-allocated computing tasks; or
in response to at least some of the to-be-allocated computing tasks being completed, submitting other computing tasks and acquiring task states and logs of the other computing tasks.
7. An apparatus for processing a gateway device fault, comprising:
a memory storing a set of instructions; and
at least one processor configured to execute the set of instructions to cause the apparatus to perform:
monitoring temporary files registered by a plurality of gateway devices during boot-up;
in response to a temporary file of the temporary files having been deleted, identifying, among the plurality of gateway devices, a gateway device corresponding to the deleted temporary file;
acquiring computing tasks being executed by the identified gateway device;
identifying to-be-allocated computing tasks among the acquired computing tasks according to parameters configured when the computing tasks are issued, the parameters indicating whether the computing tasks require failover processing;
scheduling the to-be-allocated computing tasks to one or more other gateway devices; and
recovering task states of the to-be-allocated computing tasks to enable executing each of the to-be-allocated computing tasks by the one or more other gateway devices based on the task state of each to-be-allocated computing task.
8. The apparatus of claim 7 , wherein the termination module is further configured to:
terminate the computing tasks on the gateway device after the fault is detected.
9. The apparatus of claim 8 , wherein terminating the computing tasks on the gateway device comprises:
in response to a fault type of the gateway device being network disconnection, traversing processes of the gateway device and terminating resident processes of the gateway device; and
in response to a fault type of the gateway device being process crash, terminating resident processes started by the gateway device.
10. The apparatus of claim 7 , wherein the at least one processor is configured to execute the set of instructions to cause the apparatus to perform:
scheduling the to-be-allocated computing tasks to the one or more other gateway devices according to a preset scheduling strategy.
11. An apparatus for processing a gateway device fault, comprising:
a memory storing a set of instructions; and
at least one processor configured to execute the set of instructions to cause the apparatus to perform:
acquiring computing tasks being executed by a gateway device in response to a fault on the gateway device has been detected;
identifying to-be-allocated computing tasks among the acquired computing tasks according to parameters configured when the computing tasks are issued, the parameters indicating whether the computing tasks require failover processing by at least one of:
determining whether a failover processing value of a parameter corresponding to a computer task is in a valid state;
placing the computing task into a queue as a to-be-allocated computing task if the failover processing value is in the valid state; or
setting the computing task to an error state if the failover processing value is in an invalid state; and
recovering task states of the to-be-allocated computing tasks to enable executing each of the to-be-allocated computing tasks by the one or more other gateway devices based on the task state of each to-be-allocated computing task.
12. An apparatus for processing a gateway device fault, comprising:
a memory storing a set of instructions; and
at least one processor configured to execute the set of instructions to cause the apparatus to perform:
acquiring computing tasks being executed by a gateway device in response to a fault on the gateway device has been detected;
identifying to-be-allocated computing tasks among the acquired computing tasks according to parameters configured when the computing tasks are issued, the parameters indicating whether the computing tasks require failover processing;
scheduling the to-be-allocated computing tasks to one or more other gateway devices; and
recovering task states of the to-be-allocated computing tasks to enable executing each of the to-be-allocated computing tasks by the one or more other gateway devices based on the task state of each to-be-allocated computing task, by at least one of the following:
querying task states of the to-be-allocated computing tasks;
in response to at least some of the to-be-allocated computing tasks running, acquiring task states and logs of the at least some of the to-be-allocated computing tasks;
in response to at least some of the to-be-allocated computing tasks failing to run, resubmitting the at least some of the to-be-allocated computing tasks, and acquire task states and logs of the at least some of the to-be-allocated computing tasks; and
in response to at least some of the to-be-allocated computing tasks being completed, submitting other computing tasks, and acquire task states and logs of the other computing tasks.
13. A non-transitory computer readable medium that stores a set of instructions that is executable by at least one processor of a computer to cause the computer to perform a method for processing a gateway device fault, the method comprising:
monitoring temporary files registered by a plurality of gateway devices during boot-up;
in response to a temporary file of the temporary files having been deleted, identifying, among the plurality of gateway devices, a gateway device corresponding to the deleted temporary file;
acquiring computing tasks being executed by the identified gateway device;
identifying to-be-allocated computing tasks among the acquired computing tasks according to parameters configured when the computing tasks are issued, the parameters indicating whether the computing tasks require failover processing;
scheduling the to-be-allocated computing tasks to one or more other gateway devices; and
recovering task states of the to-be-allocated computing tasks to enable executing each of the to-be-allocated computing tasks by the one or more other gateway devices based on the task state of each to-be-allocated computing task.
14. The non-transitory computer readable medium according to claim 13 , wherein the set of instructions that is executable by the at least one processor of the computer causes the computer to further perform:
terminating the computing tasks on the gateway device after the fault is detected.
15. The non-transitory computer readable medium according to claim 14 , wherein terminating the computing tasks on the gateway device comprises:
in response to a fault type of the gateway device being network disconnection, traversing processes of the gateway device and terminating resident processes of the gateway device; and
in response to a fault type of the gateway device being process crash, terminating resident processes started by the gateway device.
16. The non-transitory computer readable medium according to claim 13 , wherein scheduling the to-be-allocated computing tasks to one or more other gateway devices comprises:
scheduling the to-be-allocated computing tasks to the one or more other gateway devices according to a preset scheduling strategy.
17. A non-transitory computer readable medium that stores a set of instructions that is executable by at least one processor of a computer to cause the computer to perform a method for processing a gateway device fault, the method comprising:
acquiring computing tasks being executed by a gateway device in response to a fault on the gateway device has been detected;
identifying to-be-allocated computing tasks among the acquired computing tasks according to parameters configured when the computing tasks are issued, the parameters indicating whether the computing tasks require failover processing by at least one of:
determining whether a failover processing value of a parameter corresponding to a computer task is in a valid state;
placing the computing task into a queue as a to-be-allocated computing task if the failover processing value is in the valid state; or
setting the computing task to an error state if the failover processing value is in an invalid state; and
recovering task states of the to-be-allocated computing tasks to enable executing each of the to-be-allocated computing tasks by the one or more other gateway devices based on the task state of each to-be-allocated computing task.
18. A non-transitory computer readable medium that stores a set of instructions that is executable by at least one processor of a computer to cause the computer to perform a method for processing a gateway device fault, the method comprising:
acquiring computing tasks being executed by a gateway device in response to a fault on the gateway device has been detected;
identifying to-be-allocated computing tasks among the acquired computing tasks according to parameters configured when the computing tasks are issued, the parameters indicating whether the computing tasks require failover processing;
scheduling the to-be-allocated computing tasks to one or more other gateway devices; and
recovering task states of the to-be-allocated computing tasks to enable executing each of the to-be-allocated computing tasks by the one or more other gateway devices based on the task state of each to-be-allocated computing task, by at least one of the following:
querying task states of the to-be-allocated computing tasks; and
acquiring, in response to at least some of the to-be-allocated computing tasks running, task states and logs of the at least some of the to-be-allocated computing tasks;
resubmitting, in response to at least some of the to-be-allocated computing tasks failing to run, the at least some of the to-be-allocated computing tasks, and acquiring task states and logs of the at least some of the to-be-allocated computing tasks; and
submitting, in response to at least some of the to-be-allocated computing tasks being completed, other computing tasks, and acquiring task states and logs of the other computing tasks.