主页 / 问题 / 630039
Accepted
Alexander Pozharskii
Asked:2020-02-20 03:32:58 +0000 UTC2020-02-20 03:32:58 +0000 UTC

如何将龙卷风与 python3.5 中的异步函数一起使用（如果可能）？

  • 772

实际上，我即将结束提交服务，实际上，该服务从一项服务接收文本，处理第二项服务并将结果保存在数据库中。因此——因为大部分时间它必须等待来自其他服务的响应——我使用了异步（async/await 是在 python3.5 中引入的）。

现在您需要附加到此 webmord（1 种非参数化请求，1 种 - 参数化）。我在考虑制造龙卷风。开始很简单：

from tornado.httpserver import HTTPServer
from tornado.platform.asyncio import AsyncIOMainLoop
from tornado.web import Application, RequestHandler, asynchronous
from asyncio import sleep


class Handler(RequestHandler):
    async def get(self):
        print("Started")
        await sleep(10)
        self.write("Hello, world!")
        self.finish()


if __name__ == '__main__':
    HTTPServer(Application(
        [('/', Handler,)]
    )).listen(8888)
    AsyncIOMainLoop.instance().start()

因此 - 我以小于 20 秒的间隔向 127.0.0.1:8888/ 发出 2 个请求，两个请求的执行开始，但我没有收到响应。

python

1 个回答

  1. Best Answer

    这个选项有效。在我的例子中，事件循环的初始化似乎有问题。

    from tornado.httpserver import HTTPServer
from tornado.platform.asyncio import AsyncIOMainLoop
from tornado.web import Application, RequestHandler, asynchronous
from asyncio import sleep, get_event_loop


class Handler(RequestHandler):
    async def get(self):
        print(0)
        await sleep(10)
        print(1)
        self.write("Hello, world!")
        self.finish()


if __name__ == '__main__':
    AsyncIOMainLoop().install()
    HTTPServer(Application(
        [('/', Handler,)]
    )).listen(8888)
    get_event_loop().run_forever()
    • 0

相关问题