当前位置: 首页 > news >正文

MongoDB CRUD操作:可重试写入

MongoDB CRUD操作:可重试写入

文章目录

  • MongoDB CRUD操作:可重试写入
    • 使用的先决条件
      • 部署的限制
      • 支持的存储引擎
      • 3.6+ MongoDB 驱动程序
      • MongoDB 版本
      • 写确认
    • 可重试写入和多文档事务
    • 启用可重试写入
      • MongoDB驱动
      • mongosh
    • 可重试的写操作
    • 行为
      • 持续的网络错误
      • 故障切换周期
      • 诊断
      • 针对本地数据库的可重试写入
      • 错误处理

MongoDB的Retryable Writes是一种容错机制,旨在提高数据库操作的可靠性和稳定性。用于在遇到网络波动、副本集节点故障等临时性问题时,自动重新执行写操作。这种机制的目的是确保数据能够安全、准确地写入数据库,从而增强数据库的鲁棒性和可用性。

可重试写入

使用的先决条件

要使用可重试写入,有以下先决条件要求:

部署的限制

可重试写入需要副本集或分片集群,不支持独立实例。

支持的存储引擎

可重试写入需要支持文档级锁定的存储引擎,例如 WiredTiger 或内存存储引擎。

3.6+ MongoDB 驱动程序

客户端需要针对 MongoDB 3.6 或更高版本更新 MongoDB 驱动程序:

Java 3.6+ Python 3.6+ C 1.9+

Go 1.8+ C# 2.5+ Node 3.0+

Ruby 2.5+ Rust 2.1+ Swift 1.2+

Perl 2.0+ PHPC 1.4+ Scala 2.2+

C++ 3.6.6+

MongoDB 版本

集群中每个节点的MongoDB版本必须为3.6或更高版本,集群中每个节点的featureCompatibilityVersion必须为3.6或更高版本。有关 featureCompatibilityVersion 标志的更多信息,请参阅 setFeatureCompatibilityVersion。

写确认

写入关注值为 0 的写入操作不可重试。

可重试写入和多文档事务

事务提交和中止操作是可重试的写操作。如果提交操作或中止操作遇到错误,MongoDB 驱动程序会重试该操作一次,无论 retryWrites 是否设置为 false。

无论 retryWrites 的值如何,事务内的写入操作都不可单独重试。

启用可重试写入

MongoDB驱动

与 MongoDB 4.2 及更高版本兼容的驱动程序默认启用可重试写入。早期的驱动程序需要 retryWrites=true 选项。在使用与 MongoDB 4.2 及更高版本兼容的驱动程序的应用程序中,可以省略 retryWrites=true 选项。
要禁用可重试写入,使用与 MongoDB 4.2 及更高版本兼容的驱动程序的应用程序必须在连接字符串中包含 retryWrites=false。

mongosh

mongosh 中默认启用可重试写入。要禁用可重试写入,请使用 --retryWrites=false 命令行选项:

mongosh --retryWrites=false

可重试的写操作

当发出已确认的写关注时,以下写操作可重试;例如,写关注不能为 {w.0}: 0}.

事务内的写入操作不可单独重试。

方法说明
db.collection.insertOne()插入操作
db.collection.insertMany()插入操作
db.collection.updateOne()单文档更新操作
db.collection.replaceOne()单文档更新操作
db.collection.deleteOne()单文档删除
db.collection.remove()其中justOnetrue单文档删除
db.collection.findAndModify()单文档更新
db.collection.findOneAndDelete()单文档删除
db.collection.findOneAndReplace()单文档更新
db.collection.findOneAndUpdate()单文档更新
db.collection.bulkWrite()的写操作insertOneupdateOnereplaceOnedeleteOne只包含单文档写入操作的批量写入操作。可重试的批量操作可包括指定写入操作的任何组合,但不能包括任何多文档写入操作,如updateMany
Bulk操作的Bulk.find.removeOne()Bulk.find.replaceOne()Bulk.find.updateOne()只包含单文档写入操作的批量写入操作。可重试的批量操作可以包括指定写入操作的任何组合,但不能包括任何多文档写入操作,例如为多选项指定为true的更新

行为

持续的网络错误

MongoDB的可重试写入只进行一次重试尝试,这会有助于解决瞬时网络错误和副本集选举问题,但不能解决持续性网络错误。

故障切换周期

如果驱动程序在目标副本集或分片集群分片中找不到运行状况良好的主数据库,则驱动程序将等待serverSelectionTimeoutMS毫秒以确定新的主数据库,然后再重试。可重试写入不能解决故障转移时间超过serverSelectionTimeoutMS的情况。

如果客户端应用程序在发出写入操作后无响应的时间超过localLogicalSessionTimeoutMinutes,则当客户端应用程序开始响应(无需重新启动)时,可能会重试并再次应用写入操作。

诊断

serverStatus命令及其mongosh shell辅助程序db.serverStatus()包含事务部分中可重试写入的统计数据。

针对本地数据库的可重试写入

MongoDB 官方驱动程序默认启用可重试写入,除非显式禁用可重试写入,否则写入本地数据库的应用程序会遇到写入错误。

要禁用可重试写入,可在MongoDB集群的连接字符串中指定retryWrites=false

错误处理

从MongoDB 6.1开始,如果可重试写入的第一次和第二次尝试都失败而没有执行单个写入,则返回带有NoWritesPerformed标签的错误。NoWritesPerformed标签区分批处理操作(如 insertMany())的结果。在insertMany操作中,可能会出现以下结果之一:

结果MongoDB输出
没有插入任何文档使用NoWritesPerformed标签返回错误
部分工作已完成。 (至少插入一份文档,但不是全部。)没有NoWritesPerformed标签时返回错误
所有文档均已插入成功返回

应用程序可以使用NoWritesPerformed标签来明确没有插入任何文档,该错误报告让应用程序可以在处理可重试写入时保持数据库的准确状态。

在MongoDB的早期版本中,当第一次和第二次可重试写入尝试失败时,会返回错误。但没有任何区别来表明没有执行写入。

相关文章:

  • WebSocket首次使用踩坑记录
  • 苹果将推出“Apple Intelligence”AI系统,专注于隐私和广泛应用|TodayAI
  • KafkaStream Local Store和Global Store区别和用法
  • docker pull image 报错 dial tcp 31.13.88.169:443: i/o timeout
  • Python 识别图片形式pdf的尝试(未解决)
  • 【JSP】如何在IDEA上部署JSP WEB开发项目
  • 贪心算法-加油站
  • c#与汇川plc通信
  • STM32 HAL库开发——入门篇(3):OLED、LCD
  • 骑砍2霸主MOD开发(11)-瓦兰迪亚火骑兵
  • k8s使用yml文件部署
  • 【Vue】——组件的注册与引用
  • 默认launcher
  • 鸿蒙OS初识
  • Python的Pillow(图像处理库)的一些学习笔记
  • 分享的文章《人生如棋》
  • C++11: atomic 头文件
  • es6
  • java架构面试锦集:开源框架+并发+数据结构+大企必备面试题
  • Java知识点总结(JavaIO-打印流)
  • React as a UI Runtime(五、列表)
  • React Native移动开发实战-3-实现页面间的数据传递
  • RedisSerializer之JdkSerializationRedisSerializer分析
  • RxJS: 简单入门
  • WordPress 获取当前文章下的所有附件/获取指定ID文章的附件(图片、文件、视频)...
  • 编写高质量JavaScript代码之并发
  • 给Prometheus造假数据的方法
  • 离散点最小(凸)包围边界查找
  • 区块链分支循环
  • 网页视频流m3u8/ts视频下载
  • 自制字幕遮挡器
  • 《TCP IP 详解卷1:协议》阅读笔记 - 第六章
  • 如何正确理解,内页权重高于首页?
  • ![CDATA[ ]] 是什么东东
  • #我与Java虚拟机的故事#连载12:一本书带我深入Java领域
  • (06)金属布线——为半导体注入生命的连接
  • (20)目标检测算法之YOLOv5计算预选框、详解anchor计算
  • (24)(24.1) FPV和仿真的机载OSD(三)
  • (33)STM32——485实验笔记
  • (C语言版)链表(三)——实现双向链表创建、删除、插入、释放内存等简单操作...
  • (DenseNet)Densely Connected Convolutional Networks--Gao Huang
  • (javaweb)Http协议
  • (附源码)基于SpringBoot和Vue的厨到家服务平台的设计与实现 毕业设计 063133
  • (附源码)计算机毕业设计ssm电影分享网站
  • (每日一问)设计模式:设计模式的原则与分类——如何提升代码质量?
  • (免费领源码)Java#Springboot#mysql农产品销售管理系统47627-计算机毕业设计项目选题推荐
  • (七)MySQL是如何将LRU链表的使用性能优化到极致的?
  • (已解决)Bootstrap精美弹出框模态框modal,实现js向modal传递数据
  • (原創) 系統分析和系統設計有什麼差別? (OO)
  • (转)VC++中ondraw在什么时候调用的
  • (轉貼) 寄發紅帖基本原則(教育部禮儀司頒布) (雜項)
  • .[hudsonL@cock.li].mkp勒索病毒数据怎么处理|数据解密恢复
  • .babyk勒索病毒解析:恶意更新如何威胁您的数据安全
  • .net 7和core版 SignalR
  • .NET C# 配置 Options