玩了一个星期的clannad,是时候干点事了。 折腾了下celery周期性任务: celery提供了一个叫celery beat的服务,用于定时驱使worker执行任务。也就是说,如果本地没有活动的worker,它将不会得到任何执行结果,他只...
分类:
其他好文 时间:
2015-05-24 15:53:52
阅读次数:
399
基于Python已经有多个科学研究和数据分析库,使用非常方便。结合OpenStack(http://www.openstack.org)、RabbitMQ(http://www.rabbitmq.com)、Celery(http://www.celeryproject.org)可以打造一个实时...
分类:
编程语言 时间:
2015-05-21 15:41:56
阅读次数:
287
Celery?(芹菜)是基于Python开发的分布式任务队列。它支持使用任务队列的方式在分布的机器/进程/线程上执行任务调度。 架构设计 Celery的架构由三部分组成,消息中间件(message broker),任务执行单元(wor...
分类:
编程语言 时间:
2015-05-20 18:53:15
阅读次数:
158
celery worker guide abstract 启动worker: e.g. celery -A proj worker -l info ? ? ?celery -A proj worker --loglevel=INFO --concurrency=10 -n worker1.%h 备注: The hostname argument can expand the...
分类:
其他好文 时间:
2015-05-18 09:22:21
阅读次数:
344
起因最近打算实现异步任务,回想起当年看celery的场景,重新整理下celery的机制1. 任务入队列假定一个函数定义如下def add(a, b, c=0):
print a + b + c任务被序列化后,以字符串的形式入队列{"body": "gAJ9cQEoVQdleHBpcmVzcQJOVQN1dGNxA4lVBGFyZ3NxBF1xBShLD0sUZVUFY2hvcmRxBk5V...
分类:
其他好文 时间:
2015-05-14 14:19:07
阅读次数:
130
Main error codesError CodeDescriptionDetails and Solution80Can not initialize bar code readerPower-cycle the unit and retry the operation81No response...
分类:
其他好文 时间:
2015-05-10 22:02:01
阅读次数:
290
将要执行异步任务脚本 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
虚拟机里面做了个主从:但是IO现成一直不能跟主库上的dump现成通信,Slave_IO_Running: NoLast_IO_Error: error connecting to master 'gechong@192.168.91.128:3306' - retry-time: 5 retries...
分类:
数据库 时间:
2015-04-30 17:54:27
阅读次数:
142
这里只对其做简单笔记,group,chord等内容直接看文档 subtask实际上是一个signature,可以到处传递 一种raw的用法是: >>> from celery import signature >>> signature(‘tasks.add‘, args=(2, 2), countdown=1...
分类:
其他好文 时间:
2015-04-26 16:55:50
阅读次数:
173