如何通過uniq id獲取Gearman Jobs的狀態？

Question

我需要通過這些uniq id獲取Gearman作業的狀態，而不是通過公開的處理程序，因爲我看過的每個地方都在描述

這可能嗎？在python-gearman v.2中使用...

感謝您的協助！

Answer 1

不得不挖掘相當多的東西來解決這個問題，因爲它沒有以友好的方式暴露在python-gearman-API中。但是，您可以通過自行創建GearmanJob和GearmanJobRequest的適當實例來解決此問題。

這裏是你如何能做到這一點的一個小例子：

import gearman 

client = gearman.GearmanClient(['localhost']) 
result = client.submit_job('reverse', 'this is a string', background=True); 

你要跟蹤哪些服務器得到了處理工作（如果你有一個以上的Gearman服務器處理任務），以及任務的處理。連接信息可通過result.job.connection（.gearman_host和.gearman_port）獲得，而手柄可通過result.job.handle獲得。

要檢查創建GearmanClient當前運行作業的狀態，但只提供要查詢當前狀態的服務器：幫助

client = gearman.GearmanClient(['localhost']) 

# configure the job to request status for - the last four is not needed for Status requests. 
j = gearman.job.GearmanJob(client.connection_list[0], result.job.handle, None, None, None, None) 

# create a job request 
jr = gearman.job.GearmanJobRequest(j) 
jr.state = 'CREATED' 

# request the state from gearmand 
res = client.get_job_status(jr) 

# the res structure should now be filled with the status information about the task 
print(str(res.status.numerator) + "/" + str(res.status.denominator)) 

希望！