将要执行异步任务脚本 tasks.py：from celery import Celeryfrom celery import group# host='10.32.21.52', port=6379, db=3app = Celery('tasks', backend = 'redis://10....
分类：
其他好文 时间：
2015-04-30 19:48:07
阅读次数：
174
这里只对其做简单笔记，group，chord等内容直接看文档 subtask实际上是一个signature，可以到处传递 一种raw的用法是： >>> from celery import signature >>> signature(‘tasks.add‘, args=(2, 2), countdown=1...
分类：
其他好文 时间：
2015-04-26 16:55:50
阅读次数：
173
基本的两种task调用方式： apply_async()和delay()，前者要把参数放在元组或字典中，后者直接使用参数 快速参考： T.delay(arg, kwarg=value) always a shortcut to .apply_async. T.apply_async((arg, ), {‘kwar...
分类：
其他好文 时间：
2015-04-26 15:21:48
阅读次数：
191
初次尝试搭建django+celery+redis环境，记录下来，慢慢学习~ 1、安装apache 下载httpd-2.0.63.tar.gz，解压tar zxvf httpd-2.0.63.tar.gz,cd httpd-2.0.63, ./confi...
分类：
其他好文 时间：
2015-04-17 13:16:19
阅读次数：
983
最近看到celery文档task部分，做一下小结 实际处理时，我们可以使用一个类似于logging的模块生成日志。 对于某些任务，你可以设置当满足某些条件时，重试任务、拒绝任务或忽略任务 在定义task时，@app.task(bind=...
分类：
其他好文 时间：
2015-04-12 17:55:05
阅读次数：
201
本篇博文主要介绍在开发环境中的celery使用,请勿用于部署服务器.
许多Django应用需要执行异步任务, 以便不耽误http request的执行. 我们也可以选择许多方法来完成异步任务, 使用Celery是一个比较好的选择, 因为Celery有着大量的社区支持, 能够完美的扩展, 和Django结合的也很好. Celery不仅能在Django中使用, 还能在其他地方被大量的使用. 因此...
分类：
其他好文 时间：
2015-04-08 16:36:38
阅读次数：
180
ps：百度是xxx的走狗 回到正题，今天研究了下用一个py文件作为celery的配置文件，所以，还是参考昨天的例子：http://my.oschina.net/hochikong/blog/396079 我们把celery.py的配置项拿出来，在proj目录中创建cel...
分类：
其他好文 时间：
2015-04-05 17:36:45
阅读次数：
118
这次研究celery的Next Step部分。 先创建一个python module： mkdir?proj
cd?proj
touch?__init__.py 在proj目录中创建celery.py： from?__future__?import?absolute_import
from?celery?import?Celery
...
分类：
其他好文 时间：
2015-04-04 17:00:04
阅读次数：
182
前言以前一直有使用celery的优先级机制（基于redis的任务队列），一直很好奇它的实现机制，在查阅了部分资料后，决定写这篇文章，作为总结。1. 利用Sorted Set 实现使用Sorted Set 做优先级队列最大的优点是直观明了。ZADD key score member [[score member] [score member] ...]score 作为优先级，member 作为相应的任...
分类：
其他好文 时间：
2015-03-31 09:12:19
阅读次数：
238
sora的rpc机制打算使用celery处理，celery+rabbitmq。最近开始研究它的文档，试着写了段代码; from?celery?import?Celery
app?=?Celery(‘cagent‘,backend=‘redis://localhost‘,broker=‘amqp://guest@localh...
分类：
其他好文 时间：
2015-03-29 16:43:47
阅读次数：
125
