如何使用Python motor 驱动实现MongoDB的异步增删改查?

大晨同学_6872

大晨同学_6872

2026-08-12

636人浏览

原创

motor是唯一真正异步的mongodb python驱动,pymongo无法通过async/await实现真异步;asynciomotorclient需await初始化,连接字符串含mongodb+srv://时须手动设tls=true;insert_one/many返回封装对象,取id需用.inserted_id/.inserted_ids属性;find()返回asynciomotorcursor,须用async for或.to_list();update/delete操作不自动抛异常,需检查结果对象字段。

如何使用python motor 驱动实现mongodb的异步增删改查?

Motor 是唯一能真正异步操作 MongoDB 的 Python 驱动,pymongo 再怎么套 async/await 也会卡死事件循环 —— 它底层是同步阻塞 I/O,不是“加个 await 就变异步”。

AsyncIOMotorClient 初始化必须 await 才生效

写 client = AsyncIOMotorClient("mongodb://...") 只是创建了一个连接工厂,不触发任何网络行为。直接调 collection.find_one() 会静默失败或抛 RuntimeError: There is no current event loop in thread。

  • 必须在协程里显式 await client.admin.command("ping") 来触发连接建立和权限校验
  • 生产环境更推荐用 async with 管理生命周期,尤其短任务或测试场景
  • 别漏设关键参数:maxPoolSize=300(默认 100 容易耗尽)、retryWrites=True(副本集必需)
  • 连接字符串含 mongodb+srv:// 时,务必手动加 tls=True,否则可能连上但认证失败

insert_one / insert_many 返回值不是 dict,不能用下标取字段

很多人写 result["inserted_id"] 直接报 TypeError: 'InsertOneResult' object is not subscriptable —— Motor 返回的是封装对象,不是字典。

Li Python Sec Check
Li Python Sec Check

Python 安全规范检查工具:基于 CloudBase 规范、腾讯安全指南,LLM 智能分析(默认禁用,优先本地执行)

下载
  • insert_one 返回 InsertOneResult,取 ID 用 .inserted_id 属性
  • insert_many 返回 InsertManyResult,ID 列表在 .inserted_ids(list 类型),不是 .ids
  • 如果插入时指定了 _id(比如字符串 "user_123"),.inserted_id 就是那个值,不是 ObjectId

find() 返回游标,不能 for 循环或索引

collection.find({}) 返回的是 AsyncIOMotorCursor,它不支持同步迭代、不能 list(cursor)、也不能 cursor[0] —— 这些都会立刻报错。

  • 逐条处理用 async for doc in cursor:
  • 小批量全量加载用 await cursor.to_list(length=100);length=None 表示全取(慎用,OOM 风险高)
  • 只取第一条等价于 find_one,但若已调了 find(),可用 await cursor.next()
  • 聚合操作 aggregate() 同样返回游标,不能 await collection.aggregate(pipeline),会 TypeError

update/delete 不自动抛异常,失败需主动检查

Motor 的写操作默认“发出去就返回”,哪怕 MongoDB 回复写入失败(如唯一键冲突、类型校验失败),也不会 raise 异常 —— 这和 pymongo 行为不同,极易漏掉错误。

  • update_one 返回 UpdateResult,查 .matched_count 和 .modified_count 判断是否命中、是否真改了
  • delete_one 返回 DeleteResult,看 .deleted_count 是否为 1
  • 没匹配到文档时,modified_count == 0 是正常情况,不是错误;但 matched_count == 0 可能意味着查询条件写错了
  • 所有写操作都建议配合 upsert=True 或唯一索引 + 异常捕获来兜底

最容易被忽略的点:Motor 客户端可全局单例复用,但必须确保初始化后至少有一次 await 触发连接;另外,to_list(length=None) 在大数据集上等于把整个集合拉进内存,别在没评估数据量时乱用。

Python免费学习笔记(深入):立即使用
在学习笔记中,你将探索 Python 的核心概念和高级技巧!

相关文章

驱动精灵
驱动精灵

驱动精灵基于驱动之家十余年的专业数据积累,驱动支持度高,已经为数亿用户解决了各种电脑驱动问题、系统故障,是目前有效的驱动软件,有需要的小伙伴快来保存下载体验吧!

下载

本站声明:本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系admin@php.cn

相关专题

更多
python打包成可执行文件
python打包成可执行文件

本专题为大家带来python打包成可执行文件相关的文章,大家可以免费的下载体验。

2023.07.20

1651

4

python能做什么
python能做什么

python能做的有:可用于开发基于控制台的应用程序、多媒体部分开发、用于开发基于Web的应用程序、使用python处理数据、系统编程等等。本专题为大家提供python相关的各种文章、以及下载和课程。

2023.07.25

4104

7

format在python中的用法
format在python中的用法

Python中的format是一种字符串格式化方法,用于将变量或值插入到字符串中的占位符位置。通过format方法,我们可以动态地构建字符串,使其包含不同值。php中文网给大家带来了相关的教程以及文章,欢迎大家前来阅读学习。

2023.07.31

1649

3

python教程
python教程

Python已成为一门网红语言,即使是在非编程开发者当中,也掀起了一股学习的热潮。本专题为大家带来python教程的相关文章,大家可以免费体验学习。

2023.08.03

23697

23

python环境变量的配置
python环境变量的配置

Python是一种流行的编程语言,被广泛用于软件开发、数据分析和科学计算等领域。在安装Python之后,我们需要配置环境变量,以便在任何位置都能够访问Python的可执行文件。php中文网给大家带来了相关的教程以及文章,欢迎大家前来学习阅读。

2023.08.04

2907

5

python eval
python eval

eval函数是Python中一个非常强大的函数,它可以将字符串作为Python代码进行执行,实现动态编程的效果。然而,由于其潜在的安全风险和性能问题,需要谨慎使用。php中文网给大家带来了相关的教程以及文章,欢迎大家前来学习阅读。

2023.08.04

2927

5

scratch和python区别
scratch和python区别

scratch和python的区别:1、scratch是一种专为初学者设计的图形化编程语言,python是一种文本编程语言;2、scratch使用的是基于积木的编程语法,python采用更加传统的文本编程语法等等。本专题为大家提供scratch和python相关的文章、下载、课程内容,供大家免费下载体验。

2023.08.11

1143

5

python合并两个列表
python合并两个列表

Python是一种强大的编程语言,具有许多方便的功能和工具。在Python中,有多种方法可以合并两个列表。php中文网给大家带来了相关的教程以及文章,欢迎大家前来学习阅读。

2023.08.10

596

4

python是前端还是后端
python是前端还是后端

Python属于前端也属于后端,其灵活性和丰富的生态系统使得开发人员能够在不同的领域中灵活运用。本专题为大家提供python相关的文章、下载、课程内容,供大家免费下载体验。

2023.08.11

2283

5

热门下载

更多
网站特效
/
网站源码
/
网站素材
/
前端模板

精品课程

更多
相关推荐
/
热门推荐
/
最新课程