どのようにPythonで同期オブジェクトの反復と非同期コードを組み合わせるには？

Question

私はオブジェクトのリストを持っており、オブジェクトごとに非同期的な作業をする必要があります。

forループは同期であり、完全に進捗をブロックすると思いますか？もし私が、それを構築する方法？

Answer 1

def run(tasks): 
    # ... 

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

通常、イベントループはグローバルで、スクリプト全体のメインエントリポイントとして起動する必要があります。同じように（単一の関数runの内部でイベントループを実行する）、同じイベントループで他のコルーチンを上位コードが実行できなくなります。

あなたがこれを理解して、他の非同期のものと一緒に使うことができないrunの機能をブロックしたい場合は、さらにお読みください。あなたのasync_wrapperと

---

問題は、それが前のものが行われた後にのみ、次update_ocr_task()コルーチンを待っていることです。 forループは、「ブロッキング」と呼ばれるものではありませんが、同時ではありません。非同期パラダイムによって提供される利点は使用されません。

asyncioを使用する利点を得るには、複数のコルーチンを同時に実行する必要があります。それを行うための一般的な方法は、asyncio.gather()を使用することです：

async def async_wrapper(): 

    async def process_single_task(task): 
     resolver = aiohttp.AsyncResolver() 
     connector = aiohttp.TCPConnector(resolver=resolver, family=socket.AF_INET) 
     async with aiohttp.ClientSession(connector=connector) as session: 
      await session.get(...) # do all job for *single* local task here. 

    # Run multiple task processing coroutines concurrently: 
    await asyncio.gather(
     *[process_single_task(t) for t in tasks] 
    ) 

あなたはまた、一般的にasyncioについてthis少し答えを読むことができますしたい場合。