gearman-go/example/py/client.py

50 lines
1.5 KiB
Python
Raw Permalink Normal View History

2011-05-22 23:02:03 +08:00
#!/usr/bin/python
import gearman
def check_request_status(job_request):
if job_request.complete:
print "Job %s finished! Result: %s - %s" % (job_request.job.unique, job_request.state, job_request.result)
elif job_request.timed_out:
print "Job %s timed out!" % job_request.unique
elif job_request.state == JOB_UNKNOWN:
print "Job %s connection failed!" % job_request.unique
2011-05-22 23:02:03 +08:00
def main():
client = gearman.GearmanClient(['localhost:4730', 'otherhost:4730'])
try:
completed_job_request = client.submit_job("ToUpper", "arbitrary binary data")
check_request_status(completed_job_request)
except Exception as e:
print type(e)
2011-05-22 23:02:03 +08:00
2012-08-30 17:56:10 +08:00
try:
completed_job_request = client.submit_job("ToUpperTimeOut5", "arbitrary binary data")
check_request_status(completed_job_request)
except Exception as e:
print type(e)
2012-08-30 17:56:10 +08:00
try:
completed_job_request = client.submit_job("ToUpperTimeOut20", "arbitrary binary data")
check_request_status(completed_job_request)
except Exception as e:
print type(e)
2012-09-25 15:16:17 +08:00
try:
completed_job_request = client.submit_job("SysInfo", "")
check_request_status(completed_job_request)
except Exception as e:
print type(e)
try:
completed_job_request = client.submit_job("MemInfo", "")
check_request_status(completed_job_request)
except Exception as e:
print type(e)
2011-05-22 23:02:03 +08:00
if __name__ == '__main__':
2012-08-30 17:56:10 +08:00
main()
2011-05-22 23:02:03 +08:00