| 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 |
新闻热点
疑难解答
