Limite el tiempo de ejecución del servidor

Valores de tiempo de espera aceptados

La siguiente tabla describe el comportamiento del tiempo de espera correspondiente a los valores aceptados para timeoutMS:

Si especifica la opción timeoutMS, el controlador aplica automáticamente el tiempo de espera especificado a cada operación del servidor. El siguiente ejemplo de código especifica un tiempo de espera de 200 milisegundos a nivel de cliente y luego llama al método MongoCollection.insertOne():

val settings = MongoClientSettings.builder
  .applyConnectionString(ConnectionString("<connection string>"))
  .timeout(200L, MILLISECONDS)
  .build
val mongoClient = MongoClient(settings)
val database = mongoClient.getDatabase("db")
val collection = database.getCollection("people")
collection.insertOne(Document("name" -> "Francine Loews"))

Herencia de tiempo de espera

Al especificar la opción timeoutMS, el controlador aplica el tiempo de espera según los mismos comportamientos de herencia que las demás opciones del controlador de Scala. La siguiente tabla describe cómo se hereda el valor del tiempo de espera en cada nivel:

Para obtener más información sobre anulaciones y opciones específicas, consulte la siguiente sección Anulaciones.

Transacciones

Al crear una nueva instancia de ScalaClientSession para implementar una transacción, utilice el defaultTimeout() método al crear una ClientSessionOptions instancia. Puede usar esta opción para especificar el tiempo de espera de los siguientes métodos:

• confirmarTransacción()

• abortTransaction()

• cerca()

El siguiente código muestra cómo configurar el defaultTimeout al crear una instancia de un ClientSession:

val opts = ClientSessionOptions.builder
  .defaultTimeout(200L, MILLISECONDS)
  .build
val session = mongoClient.startSession(opts)
// ... perform operations on ClientSession

Si no especifica defaultTimeout, el controlador utiliza el valor de tiempo de espera establecido en el elemento principal MongoClient.

También puede establecer un tiempo de espera a nivel de transacción llamando al método timeout() al crear una instancia TransactionOptions. Al configurar esta opción, se aplica un tiempo de espera a todas las operaciones realizadas dentro del ámbito de la transacción:

val transactionOptions = TransactionOptions.builder
  .timeout(200L, MILLISECONDS)
  .build

Para obtener más información sobre las transacciones, consulte la Realizar una guía de transacciones.

Cifrado del cliente

Cuando usas la Encriptación de Campo a Nivel de Cliente (CSFLE), el driver utiliza la opción timeoutMS para limitar el tiempo permitido para las operaciones de encriptación y desencriptación. Puedes configurar una opción de tiempo de espera para tu instancia de ClientEncryption llamando al método timeout() al crear una instancia de ClientEncryptionSettings.

Si especifica el tiempo de espera al construir una instancia ClientEncryption, este controla la duración de todas las operaciones realizadas en esa instancia. Si no proporciona un tiempo de espera al instanciar ClientEncryption, la instancia hereda el valor de tiempo de espera del MongoClient utilizado en el constructor ClientEncryption.

Si se establece timeoutMS tanto en el cliente como directamente en ClientEncryption, se le da prioridad al valor que se proporciona a ClientEncryption.

Modo de por vida

El modo de duración utiliza la configuración de tiempo de espera para limitar la duración total de un Observable. En este modo, la aplicación debe inicializar el Observable, completar todas las llamadas a los métodos Observable y devolver todos los documentos dentro del límite de tiempo especificado. De lo contrario, la duración de Observable expira y el controlador genera un error de tiempo de espera.

El siguiente ejemplo muestra cómo establecer un tiempo de espera Observable para garantizar que el cursor esté inicializado y que todos los documentos se recuperen dentro del tiempo de espera heredado:

val observableWithLifetimeTimeout = collection
  .find(gte("age", 40))
  .timeoutMode(TimeoutMode.CURSOR_LIFETIME)