在tornado中使用会不会出现你说的与asyncio自有协程不兼容的问题？ about aioqiniu HOT 6 CLOSED

#!/usr/bin/env python3
# coding: utf-8

import asyncio
import functools

import aioqiniu
import tornado.web
from tornado.platform.asyncio import AsyncIOMainLoop

QINIU_ACCESS_KEY = "QINIU_ACCESS_KEY"
QINIU_SECRET_KEY = "QINIU_SECRET_KEY"


def convert_asyncio_future(method):
    """解决tornado中使用aiohttp的ClientSession的不兼容问题"""
    @functools.wraps(method)
    async def wrapper(self, *args, **kwargs):
        coro = method(self, *args, **kwargs)
        return await asyncio.ensure_future(coro)
    return wrapper


class QueryFileStatHandler(tornado.web.RequestHandler):
    """查询七牛云文件对象数据的请求处理器"""

    def initialize(self, qiniuclient):
        self.qiniuclient = qiniuclient

    @convert_asyncio_future
    async def get(self, bucket: str, key: str):
        res = await self.qiniuclient.get_file_stat(bucket, key)
        self.write(res)

    pass


async def create_qiniu_client(*args, **kwargs):
    """在协程中创建七牛客户端

    避免七牛客户端自动创建aiohttp的ClientSession因不在协程中创建而发出提示信息。
    """
    return aioqiniu.QiniuClient(*args, **kwargs)


def main():
    # tornado使用asyncio的主IO循环，即`asyncio.get_event_loop()`
    AsyncIOMainLoop().install()
    loop = asyncio.get_event_loop()

    qiniuclient = loop.run_until_complete(
        create_qiniu_client(QINIU_ACCESS_KEY, QINIU_SECRET_KEY))
    params = {"qiniuclient": qiniuclient}

    app = tornado.web.Application([
        (r"/query/(.*?)/(.*?)", QueryFileStatHandler, params),
    ])
    app.listen(8888)

    loop.run_forever()


if __name__ == "__main__":
    main()