在GAE中的deferred.defer中重试计数

tom*_*tom 3 python google-app-engine

我正在使用GAE的' deffered '库(python),它会在发生异常时自动重试任务.

有没有办法知道(在任务处理函数内)任务被尝试的次数?

我的最终目标是实现以下内容:

if num_tries >5:
  email_admins()
  raise deferred.PermanentTaskFailure
Run Code Online (Sandbox Code Playgroud)

最初我以为我可以使用'TaskRetryOptions'来限制尝试次数,但我相信这并没有提供我的email_admins()调用的机制.或者是吗?

[编辑]当然我可以读取/写入DB或memcache的尝试次数,但我宁愿避免这种复杂性.如果可能的话,我更愿意从任务/任务队列中获取详细信息.

luc*_*mia 7

将通过任务https://developers.google.com/appengine/docs/python/taskqueue/overview-push自动设置多个标头

X-AppEngine-TaskRetryCount,重试此任务的次数; 对于第一次尝试,此值为0.此数字包括由于缺少可用实例而从未到达执行阶段而导致任务失败的尝试.

X-AppEngine-TaskExecutionCount,此任务在执行阶段之前失败的次数.此数字不包括由于缺少可用实例而导致的故障.

编辑1

这些值可以访问:

num_tries  = self.request.headers.get('X-AppEngine-TaskRetryCount')
Run Code Online (Sandbox Code Playgroud)

编辑2

http://webapp-improved.appspot.com/api/webapp2.html#webapp2.get_request

对于deferred尝试:

request = webapp2.get_request()
Run Code Online (Sandbox Code Playgroud)

  • 我测试了它,webapp2.get_request().headers.get('X-AppEngine-TaskRetryCount')确实有效 - 谢谢! (3认同)