#!/usr/bin/env python
import sys
import json
import gearman
from fabric import *
from fabric.api import *
from gearman import GearmanWorker
#
# Run the ssh task
#
def exe_job(worker, job):
d = json.loads(job.data)
env.host_string = d['host']
cmd = d['command']
retries = int(d['retries'])
output = ""
# Run the fabric command. Do not abort on exit
# Run job for the given number of retries
tmp_retries = retries;
while retries > 0:
with settings(warn_only=True):
result = run(cmd)
output = output + str(result)
if result.failed:
if retries == 1:
job.send_fail()
break
else:
next
else:
break
retries = retries - 1
return output
#
# Main function
#
def main():
gm_worker = gearman.GearmanWorker(['localhost:4730'])
gm_worker.register_task('exe_job',exe_job)
gm_worker.work()
if __name__ == '__main__':
main()
在我的代码中,我正在尝试按照用户指定的重试次数重试 gearman 作业(运行结构命令)。对于每次尝试,我都会捕获并附加输出。在最后一次重试中,如果作业失败,我想将输出返回给客户端。
正在发生的事情是 job.send_fail() 命令简单地中断并且根本没有转到“返回输出”命令来返回失败命令的输出。
有没有更好的方法让工作失败并在退出/失败时将数据返回给客户端而不会导致工作人员死亡?