本文介绍了如何跟踪芹菜的重试情况的处理方法,对大家解决问题具有一定的参考价值,需要的朋友们下面随着跟版网的小编来一起学习吧!
问题描述
@app.task(bind=True, default_retry_delay=900, max_retries=5)
def send_email(self, sender=None, to=None, subject=None, message=None):
try:
# Send email
except Exception as e:
# Print log message with current retry
self.retry(e)
但我想说这是尝试1/5.2/5等等。
推荐答案
当前重试次数可以在任务的request.retries
属性上找到。
@app.task(retries=3, default_retry_delay=1)
def fail():
try:
assert False
except Exception as e:
print 'Try {0}/{1}'.format(fail.request.retries, fail.max_retries)
# Print log message with current retry
raise fail.retry(exc=e)
[2015-01-14 15:15:55,702: WARNING/Worker-1] Try 0/3
[2015-01-14 15:15:58,604: WARNING/Worker-3] Try 1/3
[2015-01-14 15:16:00,605: WARNING/Worker-2] Try 2/3
[2015-01-14 15:16:02,607: WARNING/Worker-6] Try 3/3
芹菜内部使用类似的方法:https://github.com/celery/celery/blob/b0cfa0d818743262a032c541cce2fa8c43fabad4/celery/app/task.py#L558
这篇关于如何跟踪芹菜的重试情况的文章就介绍到这了,希望我们推荐的答案对大家有所帮助,也希望大家多多支持跟版网!
本站部分内容来源互联网,如果有图片或者内容侵犯了您的权益,请联系我们,我们会在确认后第一时间进行删除!