mongo异步python库Motor

使用该第三方库前, 先了解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