MongoDB - 事務支持

来源:https://www.cnblogs.com/fatedeity/archive/2022/11/25/16925314.html
-Advertisement-
Play Games

在 4.2 版本及更高版本中,MongoDB 提供了事務的支持,並且在其是分散式資料庫的基礎上,提供了支持跨多個操作、集合、資料庫、文檔和分片的 ACID 事務。 ...


事務簡介

事務是資料庫中處理的邏輯單元,每個事務中包括一個或多個資料庫操作,既可以是讀操作,也可以是寫操作。

ACID 是一個“真正”事務所需要具備的一組屬性集合,指的是原子性(Atomicity)、一致性(Consistency)、隔離性(Isolation)和持久性(Durability)。

原子性指的是,事務中的所有操作要麼都被應用,要麼都不被應用。

一致性指的是,如果資料庫在執行事務之前是一致性狀態,那麼在事務執行之後,無論事務是否成功,資料庫也應該是一致性狀態。

隔離性指的是,即使資料庫中有多個事務併發地執行,各個事務之間也不會互相影響,並且在併發狀態下執行的事務和串列執行的事務產生的結果完全相同。

持久性指的是,在事務成功提交了之後,事務所變更的數據一定會保存起來,而不會因為任何故障導致數據丟失。

當資料庫滿足所有這些屬性,並且只有成功的事務才會被處理時,它就被稱為是符合 ACID 的資料庫。

如何使用事務

事務語法

MongoDB 提供了兩種 API 來使用事務:

  • 核心 API,與關係資料庫類似的語法(如 start_transactioncommit_transaction
  • 回調 API,這是使用事務的推薦方法

核心 API 不為大多數錯誤提供重試邏輯,它要求開發人員為操作、事務提交函數以及所需的任何重試和錯誤邏輯手動編寫代碼。

與核心 API 不同,回調 API 提供了一個單獨的函數,該函數封裝了大量功能,包括啟動與指定邏輯會話關聯的事務、執行作為回調函數提供的函數以及提交事務(或在出現錯誤時中止)。此函數還包含了處理提交錯誤的重試邏輯。

在 MongoDB 4.2 中添加回調 API 是為了簡化使用事務的應用程式開發,也便於添加處理事務錯誤的應用程式重試邏輯。

API 區別

核心 API 回調 API
需要顯式調用才能啟動和提交事務 啟動事務、執行指定的操作,然後提交(或在發生錯誤時終止)
不包含 TransientTransactionErrorUnknownTransactionCommitResult 的錯誤處理邏輯,而是提供了為這些錯誤進行自定義處理的靈活性 自動為 TransientTransactionErrorUnknownTransactionCommitResult 提供錯誤處理邏輯
要求為特定事務將顯式的邏輯會話傳遞給 API 要求為特定事務將顯式的邏輯會話傳遞給 API

實際使用

在一個 Python 的例子當中,使用核心 API 的偽代碼如下展示:

from pymongo import MongoClient
from pymongo.errors import ConnectionFailure, OperationFailure

# 顯式開啟一個事務會話
with client.start_session() as session:
    while True:
        try:
            with session.start_transaction():
                # 執行事務中的多個寫操作
                pass
                # 提交事務
                session.commit_transaction()
        except (ConnectionFailure, OperationFailure) as e:
            # 錯誤處理
            if e.has_error_label("UnknownTransactionCommitResult"):
                # 出現暫時性錯誤,則重試整個事務
                continue
            else:
                raise

使用核心 API 需要註意錯誤的捕捉和處理,而回調 API 就不需要註意這些,其偽代碼如下展示:

from pymongo import MongoClient

def session_callback(session):
    # 執行事務中的多個寫操作
    pass

# 顯式開啟一個事務會話
with client.start_session() as session:
    session.with_transaction(session_callback)

事務調優

在使用事務時,有幾個重要的參數需要註意。可以對它們進行調整,以確保應用程式能夠最佳地使用事務。

在 MongoDB 事務中有兩類主要的限制:

  • 第一類與事務的時間限制有關,控制特定事務可以運行多長時間、事務等待獲取鎖的時間以及所有事務將運行的最大長度
  • 第二類與 MongoDB 的 oplog 條目和單個條目的大小限制有關

時間限制

事務的預設最大運行時間是 1 分鐘。

可以通過在 mongod 實例級別上修改 transactionLifetimeLimitSeconds 的限制來增加。對於分片集群,必須在所有分片副本集成員上設置該參數。超過此時間後,事務將被視為已過期,並由定期運行的清理進程中止。清理進程每 60 秒或每 transactionLifetimeLimitSeconds/2 運行一次,以較小的值為準。

要顯式設置事務的時間限制,建議在提交事務時指定 maxTimeMS 參數。實際上會使用 maxTimeMStransactionLifetimeLimitSeconds 中的更小值。

事務等待獲取其操作所需鎖的預設最大時間是 5 毫秒。可以通過修改由 maxTransactionLockRequestTimeoutMillis 參數控制的限制來增加。如果事務在此期間無法獲得鎖,則該事務會被中止。

maxTransactionLockRequestTimeoutMillis 設置為 0 時,意味著如果事務無法立即獲得所需的所有鎖,則該事務會被中止。設置為 -1 將使用由 maxTimeMS 參數所指定的特定於操作的超時時間。

oplog 大小限制

MongoDB 會創建出與事務中寫操作數量相同的 oplog 條目。

但是,每個 oplog 條目必須在 16MB 的 BSON 文檔大小限制之內。

首發於「程式員翔仔」,點擊查看更多。


您的分享是我們最大的動力!

-Advertisement-
Play Games
更多相關文章
  • WebDAV 是超文本傳輸協議 (HTTP) 的一組擴展,為 Internet 上電腦之間的編輯和文件管理提供了標準.利用這個協議用戶可以通過Web進行遠程的基本文件操作,如拷貝、移動、刪除等。 在IIS 7.0中,WebDAV是作為獨立擴展模塊,需要單獨進行下載,而IIS 7.5以及以上版本中... ...
  • .NET 現在支持跨平臺這件事情已經是眾所周知的特點了,雖然平臺整體支持跨平臺了,但是我們的代碼如果真的想要實現跨平臺運行其實還是有些小細節要註意的,今天想要記錄分享的就是關於 文件I/O操作時路徑的拼接問題。 在 Windows 環境下我們常見的路徑格式如下: D:\Software\AppDat ...
  • 本文是 《精讀 Mastering ABP Framework》 2.3 探索橫切關註點 - 使用授權和許可權系統 一節的擴充內容,重點探討了授權在分散式和微服務系統中遇到的挑戰,以及 ABP Framework 中採用的解決方案。 ...
  • 在所有監控 Linux 系統性能的工具中,Linux 的 top 命令是最好的也是最知名的一個(htop 是其升級版)。top 命令提供了 Linux 系統運行中的進程的動態實時視圖。它能顯示系統的概覽信息和 Linux 內核當前管理的進程列表。它顯示了大量的系統信息,如 CPU 使用、記憶體使用、交... ...
  • Docker和Docker-Compose簡單搭建與基本設置 一、搭建 Docker 1.第一步當然是看官方文檔 2.然後發現一大堆手動搭建的教程(然後小白就這樣搭建了),然後發現最後有一鍵搭建腳本 curl -fsSL https://get.docker.com -o get-docker.sh ...
  • 字元設備是按照位元組流進行讀寫操作的設備,讀寫數據是分先後順序的。常見的點燈、按鍵、 IIC、 SPI和LCD 等都是字元設備 。 字元設備驅動開發步驟: 總體思路: 定義並初始化一個字元設備 -1、定義一個字元設備—>struct cdev 2、定義並初始化字元設備的文件操作集—>struct fi ...
  • 使用的MCU型號為 AIR32F103CCT6. 通過工作機制和示例代碼, 說明如何使用AIR32自帶的記憶體實現簡單的語音錄製和播放功能, 以及使用 ADPCM 對音頻數據進行壓縮, 提高錄製時長. 通過這些機制, 可以快速擴充為實用的錄製設備, 例如外掛I2C或SPI存儲, 或提升無線傳輸的音質,... ...
  • Python基礎之MySQL資料庫 一、SQL語句常用查詢方法 前期數據準備 ​ 為了更加直觀的展示、演示SQL語句查詢關鍵字,需導入下列表格與記錄(數據) ​ 模擬公司,導入創建公司員工表,表內包含:ID、姓名、年齡、工作時間、崗位 創建人員表格: create table emp( id int ...
一周排行
    -Advertisement-
    Play Games
  • 1.部署歷史 猿友們好,作為初來實習的我,已經遭受社會的“毒打”,所以請容許我在下麵環節適當吐槽,3Q! 傳統部署 ​ 回顧以往在伺服器部署webapi項目(非獨立發佈),dotnet環境、守護進程兩個逃都逃不掉,正常情況下還得來個nginx代理。不僅僅這仨,可能牽扯到yum或npm。node等都要 ...
  • 隨著技術的進步,跨平臺開發已經成為了標配,在此大背景下,ASP.NET Core也應運而生。本文主要基於ASP.NET Core+Element+Sql Server開發一個校園圖書管理系統為例,簡述基於MVC三層架構開發的常見知識點,前一篇文章,已經簡單介紹瞭如何搭建開發框架,和登錄功能實現,本篇... ...
  • 這道題只要會自定義cmp恰當地進行排序,其他部分沒有什麼大問題。 上代碼: 1 #include<bits/stdc++.h> 2 using namespace std; 3 int n,s,h1,h2,cnt; 4 struct apple{ 5 int height,ns;//height為蘋 ...
  • 這篇文章主要描述RPC的路由策略,包括為什麼需要請求隔離,為什麼不在註冊中心中實現請求隔離以及不同粒度的路由策略。 ...
  • 簡介: 中介者模式,屬於行為型的設計模式。用一個中介對象來封裝一系列的對象交互。中介者是各對象不需要顯式地相互引用,從而使其耦合鬆散,而且可以獨立地改變他們之間的交互。 適用場景: 如果平行對象間的依賴複雜,可以使用中介者解耦。 優點: 符合迪米特法則,減少成員間的依賴。 缺點: 不適用於系統出現對 ...
  • 【前置內容】Spring 學習筆記全系列傳送門: Spring學習筆記 - 第一章 - IoC(控制反轉)、IoC容器、Bean的實例化與生命周期、DI(依賴註入) Spring學習筆記 - 第二章 - 註解開發、配置管理第三方Bean、註解管理第三方Bean、Spring 整合 MyBatis 和 ...
  • 簡介: 享元模式,屬於結構型的設計模式。運用共用技術有效地支持大量細粒度的對象。 適用場景: 具有相同抽象但是細節不同的場景中。 優點: 把公共的部分分離為抽象,細節依賴於抽象,符合依賴倒轉原則。 缺點: 增加複雜性。 代碼: //用戶類 class User { private $name; fu ...
  • 這次設計一個通用的多位元組SPI介面模塊,特點如下: 可以設置為1-128位元組的SPI通信模塊 可以修改CPOL、CPHA來進行不同的通信模式 可以設置輸出的時鐘 狀態轉移圖和思路與多位元組串口發送模塊一樣,這裡就不給出了,具體可看該隨筆。 一、模塊代碼 1、需要的模塊 通用8位SPI介面模塊 `tim ...
  • AOP-03 7.AOP-切入表達式 7.1切入表達式的具體使用 1.切入表達式的作用: 通過表達式的方式定義一個或多個具體的連接點。 2.語法細節: (1)切入表達式的語法格式: execution([許可權修飾符] [返回值類型] [簡單類名/全類名] [方法名]([參數列表]) 若目標類、介面與 ...
  • 測試一、虛繼承與繼承的區別 1.1 單個繼承,不帶虛函數 1>class B size(8): 1> + 1> 0 | + (base class A) 1> 0 | | _ia //4B 1> | + 1> 4 | _ib //4B 有兩個int類型數據成員,占8B,基類邏輯存在前面 1.2、單個 ...