트랜잭션

인과 관계 일관성

MongoDB 특정 클라이언트 세션에서 인과적 일관성 지원합니다. 인과적 일관성 모델은 분산된 시스템에서 세션 내의 작업이 인과적 순서로 실행 보장 . 클라이언트는 인과 관계 또는 작업 간의 종속성과 일관적인 결과를 관찰합니다. 예시 를 들어, 한 작업이 논리적으로 다른 작업의 결과에 따라 달라지는 일련의 작업을 수행하는 경우 모든 후속 읽기에는 종속 관계 반영됩니다.

인과적 일관성 보장하려면 클라이언트 세션이 다음 요구 사항을 충족해야 합니다.

• 세션을 시작할 때 운전자 인과적 일관성 옵션을 활성화 해야 합니다. 이 옵션은 기본값 으로 활성화되어 있습니다.

• 작업은 단일 스레드의 단일 세션에서 실행 되어야 합니다. 그렇지 않으면 세션 또는 스레드가 optime 및 클러스터 시간 값을 서로 통신해야 합니다. 이러한 값을 전달하는 두 세션의 예시 보려면 MongoDB Server 매뉴얼에서 인과적 일관성 예시 를 참조하세요.

• majority 읽기 고려 (read concern) 사용해야 합니다.

• 반드시 majority 쓰기 고려 (write concern) 사용해야 합니다. 이는 기본값 쓰기 고려 (write concern) 값입니다.

다음 표에서는 인과적으로 일관적인 세션이 제공하는 보장 에 대해 설명합니다.

Core API

Core API는 트랜잭션을 구현하기 위해 다음과 같은 메서드를 제공합니다.

• startSession(): 새 인스턴스 생성합니다.ClientSession

• startTransaction(): 새 트랜잭션을 시작합니다.

• commitTransaction(): 생성된 세션에서 활성 트랜잭션을 커밋합니다.

• abortTransaction(): 해당 트랜잭션이 생성된 세션에서 활성 트랜잭션을 종료합니다.

• endSession(): 활성 세션을 종료합니다.

이 API를 사용할 때는 다음 단계를 수행해야 합니다.

• 세션 인스턴스를 해당 세션에서 실행하려는 각 작업에 전달합니다.

• 서버 트랜잭션 오류를 식별하고 오류 처리 로직을 구현하는 catch 차단을 구현합니다.

다음 코드는 Core API를 사용하여 트랜잭션을 수행하는 방법을 보여줍니다:

async function coreTest(client) {
  const session = client.startSession();
  try {
    session.startTransaction();
    const savingsColl = client.db("bank").collection("savings_accounts");
    await savingsColl.findOneAndUpdate(
      {account_id: "9876"}, 
      {$inc: {amount: -100 }}, 
      { session });
    const checkingColl = client.db("bank").collection("checking_accounts");
    await checkingColl.findOneAndUpdate(
      {account_id: "9876"}, 
      {$inc: {amount: 100 }}, 
      { session });
    // ... perform other operations
    await session.commitTransaction();
    console.log("Transaction committed.");
  } catch (error) {
    console.log("An error occurred during the transaction:" + error);
    await session.abortTransaction();
  } finally {
    await session.endSession();
  }
}

const session = client1.startSession();
client2.db('myDB').collection('myColl').insertOne({ name: 'Jane Eyre' }, { session });

이 를 Core API 사용하는 완전히 실행 가능한 API 예시 를 보려면 사용 예시 사용을 참조하세요.

편리한 트랜잭션 API

편리한 트랜잭션 API는 트랜잭션을 구현하기 위해 다음과 같은 방법을 제공합니다.

• withSession(): 세션 내에서 전달된 콜백을 실행합니다. API는 세션의 생성 및 종료를 자동으로 처리합니다.

• withTransaction(): 트랜잭션 내에서 전달된 콜백을 실행하고 콜백이 반환되면 commitTransaction() 메서드를 호출합니다.

이러한 메서드는 콜백이 반환하는 값을 반환합니다. 예를 들어, withTransaction() 메서드에 전달한 콜백이 { hello: "world" } 문서를 반환하면 withTransaction() 메서드도 해당 문서를 반환합니다.

편리한 트랜잭션 API를 사용하면 콜백의 반환 값을 withTransaction() 및 withSession() 메서드의 반환 값으로 전파하여 코드의 다른 곳에서 사용할 수 있습니다.

이 API를 사용할 때는 다음 단계를 수행해야 합니다.

• 세션 인스턴스를 해당 세션에서 실행하려는 각 작업에 전달합니다.

• 세션의 각 작업에 대해 비동기 await 구문을 구현합니다.

• Promise.all() 메서드 호출과 같은 병렬 처리를 피하세요. 세션을 병렬로 사용하면 일반적으로 서버 오류가 발생합니다.

다음 코드는 편리한 트랜잭션 API를 사용하여 트랜잭션을 수행하는 방법을 보여줍니다.

async function convTest(client) {
  let txnRes = await client.withSession(async (session) =>
    session.withTransaction(async (session) => {
      const savingsColl = client.db("bank").collection("savings_accounts");
      await savingsColl.findOneAndUpdate(
        {account_id: "9876"}, 
        {$inc: {amount: -100 }}, 
        { session });
  
      const checkingColl = client.db("bank").collection("checking_accounts");
      await checkingColl.findOneAndUpdate(
        {account_id: "9876"}, 
        {$inc: {amount: 100 }}, 
        { session });
      // ... perform other operations
      return "Transaction committed.";
    }, null)
  );
  console.log(txnRes);
}

해당 API를 사용하는 완전히 실행 가능한 예시를 보려면 편리한 트랜잭션 API 사용 예시를 참조하세요.

편리한 트랜잭션 API 오류 처리

편리한 트랜잭션 API 이러한 오류 유형에 대한 재시도 로직이 통합되어 있습니다. 운전자 성공적인 커밋 있을 때까지 트랜잭션 자동으로 재시도합니다.

핵심 API 오류 처리

코어 API 사용하여 트랜잭션 수행하는 경우 애플리케이션 에 다음 오류 처리 함수를 추가해야 합니다.

• 운전자 다음과 같은 경우 전체 트랜잭션 재시도하는 함수입니다. TransientTransactionError

• 운전자 다음과 같은 경우 커밋 작업을 다시 시도하는 함수입니다. UnknownTransactionCommitResult

이러한 함수는 커밋 성공적인 하거나 다른 오류가 발생할 때까지 실행 되어야 합니다. 이 재시도 로직의 예시 는 서버 매뉴얼의 드라이버 API 페이지에 있는 코어 API 섹션을 참조하세요.