db.collection.bulkWrite() (método de mongosh)

Parámetros

El método bulkWrite() acepta los siguientes parámetros:

Operaciones de escritura

db.collection.bulkWrite( [
   { insertOne : { "document" : <document> } }
] )

db.collection.bulkWrite( [
   { updateOne :
      {
         "filter": <document>,
         "update": <document or pipeline>,
         "upsert": <boolean>,
         "collation": <document>,
         "arrayFilters": [ <filterdocument1>, ... ],
         "hint": <document|string>
      }
   }
] )

db.collection.bulkWrite( [
   { updateMany :
      {
         "filter" : <document>,
         "update" : <document or pipeline>,
         "upsert" : <boolean>,
         "collation": <document>,
         "arrayFilters": [ <filterdocument1>, ... ],
         "hint": <document|string>
      }
   }
] )

db.collection.bulkWrite([
   { replaceOne :
      {
         "filter" : <document>,
         "replacement" : <document>,
         "upsert" : <boolean>,
         "collation": <document>,
         "hint": <document|string>
      }
   }
] )

db.collection.bulkWrite([
   { deleteOne : {
      "filter" : <document>,
      "collation" : <document>                   // Available starting in 3.4
   } }
] )

db.collection.bulkWrite([
   { deleteMany: {
      "filter" : <document>,
      "collation" : <document>                    // Available starting in 3.4
   } }
] )

_id Campo

Si el documento no especifica un campo _id, entonces mongod agrega el campo _id y asigna un único ObjectId() al documento antes de insertarlo o actualizarlo. La mayoría de los controladores crean un ObjectId e insertan el campo _id, pero el mongod creará y completará el _id si el controlador o la aplicación no lo hace.

Si el documento contiene un campo _id, el valor de _id debe ser único dentro de la colección para evitar un error de clave duplicada.

Las operaciones de actualización o reemplazo no pueden especificar un valor _id que sea diferente del documento original.

Ejecución de operaciones

El parámetro ordered controla si las operaciones se ejecutan en serie o en cualquier orden.

Con ordered : true (valor predeterminado), las operaciones se ejecutan en serie. Si se produce un error, las operaciones posteriores no se ejecutan.

Con ordered : false, las operaciones pueden ejecutarse en paralelo. Todas las operaciones sin errores se completan, incluso si algunas fallan.

No hay límite para la cantidad de operaciones de escritura que un controlador puede gestionar. Los controladores agrupan los datos en lotes según el valor maxWriteBatchSize, que 100 es,000 y no se puede modificar. Si el lote contiene más 100 de,000 operaciones, el controlador lo divide en grupos más pequeños con recuentos menores o iguales al valor maxWriteBatchSize. Por ejemplo, si la operación 250 contiene,000 operaciones, el controlador crea tres lotes: dos 100 con,000 operaciones y uno con,50 000 operaciones.

Si el informe de errores de un lote individual crece demasiado, MongoDB trunca todos los mensajes de error restantes a la cadena vacía. Si hay al menos dos mensajes de error con un tamaño total superior a 1MB, se truncan.

Los tamaños y la mecánica de agrupación son detalles internos de rendimiento y están sujetos a cambios en versiones futuras.

La ejecución de una ordered lista de operaciones en una colección particionada generalmente será más lenta que la ejecución de una lista unordered, ya que con una lista ordenada, cada operación debe esperar a que la anterior termine.

Colecciones con tamaño fijo

bulkWrite() tiene restricciones sobre las colecciones limitadas:

• updateOne y updateMany lanza un WriteError si la actualización aumenta el tamaño del documento.

• replaceOne lanza un WriteError si el documento de reemplazo es más grande que el original.

• deleteOne y deleteMany arroja un WriteError en colecciones limitadas.

Error Handling

bulkWrite() Lanza una BulkWriteError excepción en caso de errores. Consulte Manejo de errores dentro de las transacciones.

Excluyendo los errores de nivel de confirmación de escritura, las operaciones ordenadas se detienen después de un error, mientras que las operaciones no ordenadas continúan procesando las operaciones de escritura restantes en la cola, a menos que se ejecuten dentro de una transacción. Vea Manejo de errores dentro de las transacciones.

Los errores de nivel de confirmación de escritura se muestran en el campo writeConcernErrors, mientras que todos los demás errores se muestran en el campo writeErrors. Si se encuentra un error, se muestra el número de operaciones de escritura exitosas en lugar de los valores _id insertados. Las operaciones ordenadas muestran el único error encontrado, mientras que las operaciones desordenadas muestran cada error en un arreglo.

Transacciones

bulkWrite() se puede utilizar dentro de transacciones distribuidas.

Ejemplo de guardado masivo no ordenado

Para especificar un bulkWrite() no ordenado, establezca ordered en false.

En una lista desordenada bulkWrite() de operaciones:

• Las operaciones pueden ejecutarse en paralelo (no está garantizado). Para obtener más detalles, consulte Operaciones ordenadas o no ordenadas.

• Las operaciones con errores no se completan.

• Se han completado todas las operaciones sin errores.

En el siguiente ejemplo:

• bulkWrite() ejecuta operaciones no ordenadas en la colección users.

• La segunda operación insertOne, que está comentada, tiene el mismo _id que la primera insertOne, lo que provoca un error de clave duplicada.

db.users.bulkWrite( [
   { insertOne: { 
      document: { 
         _id: ObjectId("67a1b2c3d4e5f6a7b8c9d0e9"),
         name: "Sansa Stark",
         email: "sansa.stark@example.com",
         password: "$2b$12$UREFwsRUoyF0CRqGNK0LzO0HM/jLhgUCNNIJ9RJAqMUQ74crlJ1Vu"
      } 
   } },
   // This insert operation with the same _id value as the one above will fail
   // { insertOne: { 
   //    document: { 
   //       _id: ObjectId("67a1b2c3d4e5f6a7b8c9d0e9"), // Duplicate _id value
   //       name: "Bran Stark",
   //       email: "bran.stark@example.com",
   //       password: "$2b$12$UREFwsRUoyF0CRqGNK0LzO0HM/jLhgUCNNIJ9RJAqMUQ74crlJ1Vu"
   //    } 
   // } },
   { updateOne: {
      filter: { name: "Catelyn Stark" },
      update: { $set: { email: "cat.stark@example.com" } }
   } },
   { deleteOne: { filter: { name: "Ned Stark" } } },
   { replaceOne: {
      filter: { name: "Robb Stark" },
      replacement: { 
         name: "Robb Stark",
         email: "robb.stark@example.com",
         password: "$2b$12$NewPasswordHashHere123456789012345678901234567890"
      }
   } }
],
{ ordered: false } 
)

La segunda operación insertOne falla debido al error de clave duplicada. En un bulkWrite() desordenado, MongoDB completa cualquier operación sin errores.

Errores de nivel de confirmación de escritura (write concern) en clústeres particionados

Cuando bulkWrite() se ejecuta en en un clúster mongos fragmentado,writeConcernError siempre se informa un en la respuesta, incluso si se producen uno o más errores. En versiones anteriores, otros errores a veces provocaban bulkWrite() que no informara errores de escritura.

Por ejemplo, si un documento no supera la validación, activando un error DocumentValidationFailed, y también ocurre un error de nivel de confirmación de escritura, tanto el error DocumentValidationFailed como el writeConcernError se devuelven en el campo de nivel superior de la respuesta.

Ejemplo de guardado masivo con nivel de confirmación de escritura

El siguiente ejemplo bulkWrite() ejecuta operaciones en la colección users y establece un nivel de confirmación de escritura "majority" con un tiempo de espera de 100 milisegundos:

db.users.bulkWrite( [
   { updateMany: {
      filter: { name: { $regex: /Stark$/ } },
      update: { $set: { house: "Stark", verified: false } }
   } },
   { updateOne: {
      filter: { name: "Ned Stark" },
      update: { $set: { title: "Lord of Winterfell" } }
   } },
   { updateOne: {
      filter: { name: "Catelyn Stark" },
      update: { $set: { title: "Lady of Winterfell" } }
   } } ],
   { writeConcern: { w: "majority", wtimeout: 100 } }
)

Si el tiempo que tarda la mayoría de los miembros del conjunto de réplicas en reconocer las operaciones supera wtimeout, el ejemplo devuelve un error de escritura y un resumen de las operaciones completadas.