基础入门_Python-模块和包.深入Celery之任务绑定/记录日志/自动重试?
2016-12-29 22:49
691 查看
异常处理:
1. 当装饰器@app.task添加bind=True时,被修饰的函数第一个参数被作为任务对象,通过self可获取任务的上下文,get_task_logger其实是调用的进线程安全的logging模块,用于终端打印调试.
注意: 运行时可以celery worker -A work.app -l info,然后打开另一个终端尝试from work.notify.email import send_mail;send_mail.delay('usr', 'sub', 'msg')触发任务,观察日志.
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动态类型的学习---引用的理解
- Python3写爬虫(四)多线程实现数据爬取
- 垃圾邮件过滤器 python简单实现
- 下载并遍历 names.txt 文件,输出长度最长的回文人名。
- install and upgrade scrapy
- Scrapy的架构介绍
- Centos6 编译安装Python
- 使用Python生成Excel格式的图片
- 让Python文件也可以当bat文件运行
- [Python]推算数独
- Python中zip()函数用法举例
- Python中map()函数浅析
- Python将excel导入到mysql中
- Python在CAM软件Genesis2000中的应用
- 使用Shiboken为C++和Qt库创建Python绑定
- FREEBASIC 编译可被python调用的dll函数示例
- Python 七步捉虫法