如何获取异步协程python的返回值

Question

我是 python 新手，正在尝试学习 asyncio 模块。我对从异步任务中获取返回值感到沮丧。有一个帖子here 谈到了这个话题，但它无法分辨哪个任务返回哪个值（假设某个网页响应比另一个更快）。
下面的代码尝试同时获取三个网页，而不是一个一个地进行。

    import asyncio
    import aiohttp

    async def fetch(url):
        async with aiohttp.ClientSession() as session:
            async with session.get(url) as resp:
                assert resp.status == 200
                return await resp.text()

    def compile_all(urls):
        tasks = []
        for url in urls:
            tasks.append(asyncio.ensure_future(fetch(url)))
        return tasks

    urls = ['https://python.org', 'https://google.com', 'https://amazon.com']
    tasks = compile_all(urls)
    loop = asyncio.get_event_loop()
    a, b, c = loop.run_until_complete(asyncio.gather(*tasks))
    loop.close()

    print(a)
    print(b)
    print(c)

首先，虽然它确实打印了一些 html 文档，但它遇到了 Runtimeerror：RuntimeError: Event loop is closed。

第二，问题是：这真的保证a,b,c会依次对应urls[0],url[1],urls[2]网页的urls列表吗？ （我认为异步任务的执行不能保证这一点）。

第三，任何其他更好的方法或在这种情况下我应该使用队列吗？如果是，怎么做？

任何帮助将不胜感激。

Answer 1

结果的顺序将与 url 的顺序相对应。查看asyncio.gather 的文档：

如果所有 awaitables 都成功完成，结果是 返回值的聚合列表。结果值的顺序 对应于 aws 中 awaitable 的顺序。

要在任务完成时处理任务，您可以使用asyncio.as_completed。这个post 有更多关于如何使用它的信息。