motor

motor

MongoDB 的异步驱动

Usage

import asyncio
from motor.motor_asyncio import AsyncIOMotorClient

async def main():
    # 连接 MongoDB 数据库
    client = AsyncIOMotorClient('mongodb://localhost:27017')
    db = client['test_database']
    collection = db['test_collection']
    
    # 插入文档
    await collection.insert_one({'name': 'Alice', 'age': 30})
    
    # 查询文档
    cursor = collection.find({'age': {'$gte': 25}})
    async for document in cursor:
        print(document)
    
    # 更新文档
    await collection.update_one({'name': 'Alice'}, {'$set': {'age': 35}})
    
    # 删除文档
    await collection.delete_many({'age': {'$lt': 30}})
    
    # 断开连接
    client.close()

# 运行主函数
asyncio.run(main())