19

Python 3.5 が導入されたため、ドキュメントでasync with推奨されている構文が変更されました。彼らが提案する単一のURLを取得するには：aiohttp

import aiohttp
import asyncio

async def fetch(session, url):
    with aiohttp.Timeout(10):
        async with session.get(url) as response:
            return await response.text()

if __name__ == '__main__':
    loop = asyncio.get_event_loop()
    with aiohttp.ClientSession(loop=loop) as session:
        html = loop.run_until_complete(
            fetch(session, 'http://python.org'))
        print(html)

これを変更して、1 つの URL ではなく、URL のコレクションを取得するにはどうすればよいですか?

古いasyncio例では、次のようなタスクのリストを設定します。

    tasks = [
            fetch(session, 'http://cnn.com'),
            fetch(session, 'http://google.com'),
            fetch(session, 'http://twitter.com')
            ]

このようなリストを上記のアプローチと組み合わせようとしましたが、失敗しました。

4

1 に答える 1

42

並列実行にはasyncio.Taskが必要です

私はあなたの例をいくつかのソースからの同時データフェッチに変換しました:

import aiohttp
import asyncio

async def fetch(session, url):
    async with session.get(url) as response:
        if response.status != 200:
            response.raise_for_status()
        return await response.text()

async def fetch_all(session, urls):
    tasks = []
    for url in urls:
        task = asyncio.create_task(fetch(session, url))
        tasks.append(task)
    results = await asyncio.gather(*tasks)
    return results

async def main():    
    urls = ['http://cnn.com',
            'http://google.com',
            'http://twitter.com']
    async with aiohttp.ClientSession() as session:
        htmls = await fetch_all(session, urls)
        print(htmls)

if __name__ == '__main__':
    asyncio.run(main())
于 2016-03-09T19:07:25.443 に答える