Python asyncio-motorが非同期で動作しない

Question

私はAsynかどうかをチェックするために以下の例を試しました。しかし、それは動作していないようです。私は以下のコードを使用しました。

import asyncio 
import time 
from motor.motor_asyncio import AsyncIOMotorClient 


async def get_all_from_coll(col): 
    client = AsyncIOMotorClient("localhost", 27017) 
    db = client.project_matrix 
    cursor = db[col].find() 
    time.sleep(5) 
    for document in await cursor.to_list(length=100): 
     print(document) 


loop = asyncio.get_event_loop() 
print('001') 
loop.run_until_complete(get_all_from_coll('users')) 
print('002') 

私は出力が順番

>>>001 
>>>{'_id': ObjectId('58d9b178d011b53743d44413'), 'username': 'test1', 'password': 'test', '__v': 0} 
>>>{'_id': ObjectId('58d9b229d011b53743d44414'), 'username': 'test2', 'password': 'test', '__v': 0} 
>>>002 

以下に私が何か間違ったことをやって取得していますか？

Answer 1

for document in await cursor.to_list(length=100): 
    # (wrong) 

これはforループを開始する前に終了するcursor.to_list()を待ちます。非同期forループ（1-文書アット-時間）、you should use an async for実行するには：

async for document in cursor.limit(100): 
    # (ok) 

---

をしかし、あなたのprint("002")がloop.run_until_complete後を実行しているので、私はあなたに問題が表示されません出力順序。

Answer 2

async forを使用するか、await cursor.to_list()を使用するかは関係ありません。どちらの場合も、少なくとも1つのブロックが存在します。 awaitカーソルが使用されている場合は、1回のみブロックし、async forは複数のブロックを持つことができます。