from async_pymongo import AsyncClient async def main(): conn = AsyncClient("mongodb://...") db = conn["database_name"] col = db["collections_name"] await col.insert_one({"name": "John Smith", "age": 25}) async for data in col.find({}): print(data["name"])