| 12345678910111213141516171819202122232425262728 | #!/usr/bin/env python# -*- coding: utf-8 -*-# @Date : 2016-12-24 17:07:50# @Author : 李滿滿 (xmdevops@vip.QQ.com)# @Link : http://xmdevops.blog.51cto.com/# @Version : $Id$from __future__ import absolute_import# 說明: 導入公共模塊import socketfrom celery.utils.log import get_task_logger# 說明: 導入其它模塊from ..app import applogger = get_task_logger(__name__)@app.task(bind=True)def send_mail(self, usr, sub, msg): logger.info( ''' task_id : {0.id} task_args : {0.args!r} task_kwargs: {0.kwargs!r} '''.format(self.request) ) try: raise socket.error except socket.error, e: self.retry(exc=e, countdown=5, max_retries=3) finally: pass |
新聞熱點
疑難解答
