tornado中使用celery实现异步MySQL查询

用tornado快一年了，做的项目访问量也不大，除了在一些耗时的网络操作上，没怎么考虑异步的问题。

正在做的一个项目，需要对MySQL中的大量数据进行操作，有的请求需要耗时10s左右，当然，你也知道，别的请求就没响应了。

查了很多资料，目前采用tornado-celery这个项目，将celery和tornado结合起来，实现异步MySQL查询。

celery 是一个专注于实时处理的任务队列，celery 需要一个broker（中间人）来发送和接收消息，最佳的broker当然是RabbitMQ，是AMPQ协议的一种实现，下面具体说一下怎么操作。

安装 RabbitMQ

Mac 上用 HomeBrew 安装 brew install rabbitmq

安装成功之后启动服务

sudo rabbitmq-server -detached

安装celery

pip install celery

安装tornado-celery

pip install celery

创建tasks.py

celery = Celery('tasks', broker='amqp://')celery.conf.CELERYRESULTBACKEND = os.environ.get('CELERYRESULTBACKEND', 'amqp')
@celery.task(name='task.queryusers')def queryusers():    # 数据查询的耗时操作    users = db.queryusers()    return users

运行tasks.py

python tasks.py worker --loglevel=info

建handler

from tasks import query_usersclass UserHandler(RequestHandler):
@asynchronousdef get(self, *args, **kwargs):    query_users.apply_async(args=[], callback=self.on_success)
def on_success(self, response):    self.write(str(response.result)    self.finish()

原文地址：tornado中使用celery实现异步MySQL查询, 感谢原作者分享。 微风吹过，海面上金光闪闪，泛起一道道美丽的浪花，