使用该第三方库前, 先了解python asyncio
-
安装
python3 -m pip install motor
# motor版本要求:
python>=3.5
pymongo>=3.12 -
创建客户端
client = motor.motor_asyncio.AsyncIOMotorClient('localhost', 27017)
or
client = motor.motor_asyncio.AsyncIOMotorClient('mongodb://{用户}:{密码}@{host}:{port}', maxPoolSize=50) -
获取数据库
db = client.test_database
or
db = client['test_database']
# 这个过程没有io操作,不需要await -
获取集合
collection = db.test_collection
or
collection = db['test_collection']
# 同样没有io操作 -
插入单条文档
doc = {'name': "xxx"}
result = await db.test_collection.insert_one(doc) -
批量插入文档
doc_list = [{'name': 'xxx'},{'name': 'yyy'},...]
result = await db.test_collection.insert_many(doc_list) -
查找单条文档
doc = await db.test_collection.find_one({'name': 'xxx'}) -
查询多个文档
# 查询多个文档使用find()方法,这个方法没有i/o,不需要await,它只是创建了一个AsyncIOMotorCursor实例,当被调用时,查询实际上是在服务器上执行的.
# 基本使用
cursor = db.test_collection.find({'age':{'$lt':10}}).sort('age',-1).skip(2).limit(2)
async for doc in cursor:
... -
统计文档数
n = await db.test_collection.count_documents({'age':{'$lt':10}}) -
更新文档
# 单个文档全部更新
result = await db.test_collection.replace_one({filter},{})
# 单个文档部分更新
result = await db.update_one({filter},{'$set':{}}) -
删除文档
res = db.test_collection.delete_many({filter}) -
更多详细内容
https://motor.readthedocs.io/en/stable/api-tornado/motor_client.html