Tornado Celery Redis实现异步
Tornado Celery Redis实现异步
苏格兰雨季 发表于3年前
Tornado Celery Redis实现异步
  • 发表于 3年前
  • 阅读 342
  • 收藏 0
  • 点赞 0
  • 评论 0

华为云·免费上云实践>>>   

摘要: Tornado Celery Redis实现异步执行

Celery中两个基本的概念:Broker、Backend

    Broker :其实就是一开始说的 消息队列 ,用来发送和接受消息。

    Broker有几个方案可供选择:RabbitMQ,Redis,数据库等

    Backend : 作用是保存结果和状态,可以是Database backend,也可以是Cache backend

    Backend有几个方案可供选择:http://docs.celeryproject.org/en/latest/configuration.html#celery-result-backend

安装:

pip install celery
pip install tornado-redis
yum install redis

示例:

  tasks.py

from time import sleep
from celery import Celery

backend = 'redis://127.0.0.1:6379/0'
broker = 'redis://127.0.0.1:6379/1'

app = Celery('tasks', backend=backend, broker=broker)

@app.task
def add(x, y):
	 sleep(10)
	 return x + y

运行服务:

celery -A tasks worker --loglevel=info

测试:

>>> from tasks import add
>>> r = add.delay(4, 4)
>>> r.ready() # 10s内执行,会输出False,因为add中sleep了10s,10s之后返回True
>>>False
>>> r.status #任务状态
'PENDING'
>>> r.result  # 输出你的hostname
>>>8
>>> r.status
'SUCCESS'

Tronado:

from concurrent.futures import ThreadPoolExecutor

class SleepHandler(tornado.web.RequestHandler):
    executor = ThreadPoolExecutor(2)
    @tornado.web.asynchronous
    @tornado.gen.coroutine
    def get(self):
        res = yield self.sleep(10,10)
        self.finish()

    @run_on_executor
    def sleep(x,y):
        time.sleep(5)
        return x+y


共有 人打赏支持
粉丝 2
博文 15
码字总数 2054
×
苏格兰雨季
如果觉得我的文章对您有用,请随意打赏。您的支持将鼓励我继续创作!
* 金额(元)
¥1 ¥5 ¥10 ¥20 其他金额
打赏人
留言
* 支付类型
微信扫码支付
打赏金额:
已支付成功
打赏金额: