Transacciones

Coherencia causal

MongoDB permite la consistencia causal en ciertas sesiones de cliente. El modelo de consistencia causal garantiza que, en un sistema distribuido, las operaciones dentro de una sesión se ejecuten en un orden causal. Los clientes observan resultados consistentes con las relaciones causales o las dependencias entre operaciones. Por ejemplo, si se realiza una serie de operaciones donde una depende lógicamente del resultado de otra, las lecturas posteriores reflejan la relación de dependencia.

Para garantizar la coherencia causal, las sesiones de los clientes deben cumplir los siguientes requisitos:

• Al iniciar una sesión, el controlador debe habilitar la opción de consistencia causal. Esta opción está habilitada por defecto.

• Las operaciones deben ejecutarse en una sola sesión en un solo subproceso. De lo contrario, las sesiones o subprocesos deben comunicarse entre sí los valores de tiempo de la operación y del clúster. Para ver un ejemplo de dos sesiones que comunican estos valores, consulte los ejemplos de consistencia causal en el manual de MongoDB Server.

• Debes utilizar un majority leer preocupación.

• Debe usar un majority nivel de confirmación de escritura (write concern). Este es el valor predeterminado de nivel de confirmación de escritura (write concern).

La siguiente tabla describe las garantías que brindan las sesiones causalmente consistentes:

Core API

La API principal proporciona los siguientes métodos para implementar transacciones:

• startSession(): crea una nueva ClientSession instancia

• startTransaction(): inicia una nueva transacción

• commitTransaction(): confirma la transacción activa en la sesión en la que fue creada

• abortTransaction(): finaliza la transacción activa en la sesión en la que fue creada

• endSession(): finaliza la sesión activa

Debes realizar los siguientes pasos al utilizar esta API:

• Pase la instancia de sesión a cada operación que desee ejecutar en esa sesión.

• Implemente un bloque catch en el que identifique errores de transacciones del servidor e implemente la lógica de manejo de errores.

El siguiente código demuestra cómo realizar una transacción utilizando la API principal:

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 });

Para ver un ejemplo completamente ejecutable que utiliza esta API, consulte Utilice el ejemplo de usode la API principal.

API de transacciones convenientes

La API de transacciones convenientes proporciona los siguientes métodos para implementar transacciones:

• withSession(): ejecuta la devolución de llamada que se le pasa dentro de una sesión. La API gestiona la creación y finalización de la sesión automáticamente.

• withTransaction(): ejecuta la devolución de llamada que se le pasa dentro de una transacción y llama al commitTransaction() método cuando la devolución de llamada regresa.

Estos métodos devuelven el valor que devuelve la devolución de llamada. Por ejemplo, si una devolución de llamada que se pasa al método withTransaction() devuelve el documento { hello: "world" }, el método withTransaction() también lo devuelve.

Cuando utiliza la API de transacciones convenientes, puede propagar valores de retorno de la devolución de llamada como valores de retorno de los métodos withTransaction() y withSession() para trabajar con ellos en otras partes de su código.

Debes realizar los siguientes pasos al utilizar esta API:

• Pase la instancia de sesión a cada operación que desee ejecutar en esa sesión.

• Implemente la sintaxis async await para cada operación en la sesión.

• Evite el paralelismo, como llamar al método Promise.all(). Usar sesiones en paralelo suele provocar errores del servidor.

El siguiente código demuestra cómo realizar una transacción mediante la API de transacciones convenientes:

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);
}

Para ver un ejemplo completamente ejecutable que utiliza esta API, consulte el ejemplo de uso de la API de transacciones convenientes.

Manejo conveniente de errores de API de transacciones

La API de Transacciones Convenientes incorpora lógica de reintento para estos tipos de error. El controlador reintenta automáticamente la transacción hasta que se confirma correctamente.

Manejo de errores de la API principal

Si está utilizando la API principal para realizar una transacción, debe agregar las siguientes funciones de manejo de errores a su aplicación:

• Una función que vuelve a intentar toda la transacción cuando el conductor encuentra un TransientTransactionError

• Una función que vuelve a intentar la operación de confirmación cuando el controlador encuentra un UnknownTransactionCommitResult

Estas funciones deben ejecutarse hasta que se confirme correctamente o se produzca un error diferente. Para ver un ejemplo de esta lógica de reintento, consulte la sección API principal en la página API de controladores del manual del servidor.