您的位置:首页 > 编程语言 > Python开发

基础入门_Python-模块和包.深入Celery之任务绑定/记录日志/自动重试?

2016-12-29 22:49 691 查看
异常处理:
1. 当装饰器@app.task添加bind=True时,被修饰的函数第一个参数被作为任务对象,通过self可获取任务的上下文,get_task_logger其实是调用的进线程安全的logging模块,用于终端打印调试.
#!/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 socket
from celery.utils.log import get_task_logger
# 说明: 导入其它模块
from ..app import app
logger = 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
说明: 错误处理主要是为了重试一些由于网络抖动等原因导致的任务失败,推荐将每个可重试的任务添加一个重试时间和最大重试次数,其实既可以在self.retry中指定,也可在@app.task修饰器中添加.
注意: 运行时可以celery worker -A work.app -l info,然后打开另一个终端尝试from work.notify.email import send_mail;send_mail.delay('usr', 'sub', 'msg')触发任务,观察日志.
内容来自用户分享和网络整理,不保证内容的准确性,如有侵权内容,可联系管理员处理 点击这里给我发消息
标签:  Python 基础入门