Asyncio 没有并行运行 Aiohttp 请求

Question

我想使用 python 并行运行许多 HTTP 请求。 我用 asyncio 尝试了这个名为 aiohttp 的模块。

import aiohttp
import asyncio

async def main():
    async with aiohttp.ClientSession() as session:
        for i in range(10):
            async with session.get('https://httpbin.org/get') as response:
                html = await response.text()
                print('done' + str(i))

loop = asyncio.get_event_loop()
loop.run_until_complete(main())

我希望它并行执行所有请求，但它们是一个接一个执行的。 虽然，后来我用线程解决了这个问题，但我想知道这有什么问题？

Answer 1

您需要以并发方式发出请求。目前，您有一个由main() 定义的任务，因此http 请求以串行方式为该任务运行。

如果您使用的是抽象出事件循环创建的 Python 版本 3.7+，您也可以考虑使用 asyncio.run()：

import aiohttp
import asyncio

async def getResponse(session, i):
    async with session.get('https://httpbin.org/get') as response:
        html = await response.text()
        print('done' + str(i))

async def main():
    async with aiohttp.ClientSession() as session:
        tasks = [getResponse(session, i) for i in range(10)] # create list of tasks
        await asyncio.gather(*tasks) # execute them in concurrent manner

asyncio.run(main())