python - 如何通过他们的唯一 ID 获取 Gearman Jobs 的状态？

Question

我需要通过这些 un​​iq 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))

希望对您有所帮助!