tornado中使用celery实现异步MySQL操做

时间 2019-11-10

标签 tornado 使用 celery 实现异步 mysql 栏目 Python 繁體版

原文原文链接

tornado-celery 是基于celery的tornado客户端，经过tornado-celery能够将耗时任务加入到任务队列中处理，在celery中建立任务，tornado中就能够像调用AsyncHttpClient同样调用这些任务。python

使用celery须要选择一种broker（中间人）进行消息的接受和发送，中间人一般做为一种独立的服务，经常使用的broker又RabbitMQ、Redis以及MongoDB等。git

RabbitMQ 是AMPQ高级消息队列协议的实现，是使用最普遍的消息系统，由于tornado-celery中使用redis没法使用callback，建议使用RabbitMQ做为broker。github

下面是准备工做redis

安装tornado、celery、tornado-celery数据库
安装RabbitMQ
mac上使用brew安装该服务程序app
```
brew install rabbitmq
```
启动rabbitmq-server异步
```
sudo rabbitmq-server -detached
```

准备工做完成后就能够编码了async

建立tasks.pytornado

celery = Celery('tasks', broker='amqp://')
celery.conf.CELERY_RESULT_BACKEND = os.environ.get('CELERY_RESULT_BACKEND', 'amqp')

@celery.task(name='task.query_users')
def query_users(admin_id):
    # 耗时的数据库操做
    return db.query_all_users(admin_id)

运行tasks.py编码
```
python tasks.py worker --loglevel=info
```
建立handler

import tcelery
    tcelery.setup_nonblocking_producer()

    from tasks import query_users
    
    calss Users(RequestHandler):
        @asynchronous
        def get():
            # 参数经过args的list传递，回调经过callback指定
            query_users.apply_async(args=[admin_id], callback=self.on_success)
        def on_success(self, response):
            # 获取返回的结果
            users = response.result
            self.write(users)
            self.finish()

这样，query_users的请求就变成异步非阻塞的了，同理，其余的耗时操做能够放到task中供tornado的请求调用。