tornado和celery很配呦

Celery 是一个简单、灵活且可靠的，处理大量消息的分布式系统，并且提供维护这样一个系统的必需工具。它是一个专注于实时处理的任务队列，同时也支持任务调度。在我们日常的开发中，或多或少都会用到，一些比较耗时的异步任务，一些定时的任务都可以用celery去做。

在tornado中如果想使用celery，首先要安装celery的python api。使用pip install celery就可以了，非常方便。

  1. from celery import Celery, task
  3. c = Celery()
  5. 这是最基本的用法。
  7. 我们想要定义一个任务，我们就可以写一个很普通的方法，比如
  9. @task
  10. def mytask(a):
  11.     print 1111
  13. 只要加上@task这样一个装饰器，它就会标识为一个celery的task。我们就可以调用他了。
  15. 首先我们要启动celery，下面是我的启动命令
  16. celery -A my.utils.async_task worker -P gevent -c 2 -l info -n 'my.worker.%%h.%(ENV_USER)s'
  18. 相关参数官方文档中都可以查到，这里就不一一详述了。
  20. 调用的时候，我们要这样
  22. v = mytask.apply_async(111, countdown=1)
  23. 他的返回值是他的任务id，通过任务id，我们可以取消任务,countdown代表多少秒以后执行
  25. revoke函数就是取消任务的，revoke(task_id)