所以我需要为列表中的所有项目调用async函数.这可能是一个URL列表和一个异步函数，使用aiohttp从每个URL返回响应.显然，我无法做到以下几点:
async for url in ['www.google.com', 'www.youtube.com', 'www.aol.com']:
我可以使用普通的for循环，但我的代码将同步运行，我失go 了async响应获取函数的优势和速度.
我有没有办法转换一个列表，使上面的工作？我只需要把列表的__iter__()改成__aiter__()，对吗？这可以通过对列表进行子类化来实现吗？也许把它封装在一个类中？
for future in asyncio.as_completed(map(fetch, urls)):
result = await future
results = await asyncio.gather(map(fetch, urls))
EDIT:如果你不介意外部依赖，你可以使用aiostream.stream.map:
from aiostream import stream, pipe
async def fetch_many(urls):
xs = stream.iterate(urls) | pipe.map(fetch, ordered=True, task_limit=10)
async for result in xs:
print(result)
您可以使用task_limit参数控制并发运行的fetch个协同程序的数量，并 Select 是按顺序获得结果，还是尽快获得结果.
请参阅本demonstration和documentation中的更多示例.
免责声明:我是项目维护者