未加星标

Python Celery

字体大小 | |
[开发(python) 所属分类 开发(python) | 发布者 店小二05 | 时间 2016 | 作者 红领巾 ] 0人收藏点击收藏
python Celery + Redis 安装 pip install -U celery[redis] 配置redis 参考 配置所使用的redis服务器 redis://:[email protected]:port/db_number Example: BROKER_URL = 'redis://localhost:6379/0' 配置redis的可见性超时 BROKER_TRANSPORT_OPTIONS = {'visibility_timeout': 3600} # 1 hour. redis中存储状态和返回值 CELERY_RESULT_BACKEND = 'redis://localhost:6379/0' 只让消息对活动的主机接受 BROKER_TRANSPORT_OPTIONS = {'fanout_prefix': True} 创建一个task.py

新建一个文件,比如叫task.py。来建立我们的hello world。

from celery import Celery # 声明任务列表的来源 app = Celery('tasks',broker='redis://localhost:6379/0') # 定义任务 @app.task def say_hello(name, words): return '%s says %s'%(words, name) 运行一个task

运行task服务,需要指定服务的源文件

celery -A 文件名,不要后缀 worker --loglevel=info -f 日志文件路径 celery -A task worker --loglevel=info celery -A XcTask.MailTask worker --loglevel=info -f /Volumes/data/Python/chichit/project/log/celery.log celery -A XcTask.MailTask:app_celery worker --loglevel=info -f /Volumes/data/Python/chichit/project/log/celery.log 停止一个celery

停止Celery

ps auxww | grep 'celery worker' | awk '{print $2}' | xargs kill -9 在命令行中调用

在Python命令行中执行

Python 3.4.3 (default, Jul 31 2015, 14:07:15) [GCC 4.2.1 Compatible Apple LLVM 6.1.0 (clang-602.0.53)] on darwin >>> sys.path.extend(['/Volumes/data/Python/chichit/project/src']) >>> from XcTask.MailTask import send_ValidateMail >>> send_ValidateMail.delay([email protected]','Ryszard Xiao','https://www.xiaocan.me',33) <AsyncResult: 883f0b78-fc69-418c-9d9d-04297af152a7> 在程序中调用

from XcTask.MailTask import send_ResetMail,send_ValidateMail cRet = send_ValidateMail.delay(n.ml_email, n.ml_uname, n.ml_link, n.ml_uid);

本文开发(python)相关术语:python基础教程 python多线程 web开发工程师 软件开发工程师 软件开发流程

主题: Python服务器360RedisAppleTIOPTSULVRY
分页:12
转载请注明
本文标题:Python Celery
本站链接:http://www.codesec.net/view/481067.html
分享请点击:


1.凡CodeSecTeam转载的文章,均出自其它媒体或其他官网介绍,目的在于传递更多的信息,并不代表本站赞同其观点和其真实性负责;
2.转载的文章仅代表原创作者观点,与本站无关。其原创性以及文中陈述文字和内容未经本站证实,本站对该文以及其中全部或者部分内容、文字的真实性、完整性、及时性,不作出任何保证或承若;
3.如本站转载稿涉及版权等问题,请作者及时联系本站,我们会及时处理。
登录后可拥有收藏文章、关注作者等权限...
技术大类 技术大类 | 开发(python) | 评论(0) | 阅读(39)