$changeStreamSplitLargeEvent (etapa de agregación)

El escenario de ejemplo en esta sección muestra el uso de $changeStreamSplitLargeEvent con una nueva colección llamada myCollection.

Cree myCollection e inserte un documento con poco menos de 16 MB de datos:

db.myCollection.insertOne(
   { _id: 0, largeField: "a".repeat( 16 * 1024 * 1024 - 1024 ) }
)

largeField contiene la letra repetida a.

Habilite changeStreamPreAndPostImages myCollectionpara, lo que permite que un flujo de cambios recupere un documento como estaba antes de una actualización (pre-imagen) y después de una actualización (post-imagen):

db.runCommand( {
   collMod: "myCollection",
   changeStreamPreAndPostImages: { enabled: true }
} )

Crea un cursor de flujo de cambios para supervisar los cambios en myCollection utilizando db.collection.watch():

myChangeStreamCursor = db.myCollection.watch(
   [ { $changeStreamSplitLargeEvent: {} } ],
   { fullDocument: "required", fullDocumentBeforeChange: "required" }
)

Para el evento de flujo de cambio:

• fullDocument: "required" incluye la imagen posterior al documento.

• fullDocumentBeforeChange: "required" incluye la preimagen del documento.

Para obtener más detalles, consulte $changeStream.

Actualiza el documento en myCollection, lo que también produce un evento de flujo de cambios con las imágenes previas y posteriores del documento:

db.myCollection.updateOne(
   { _id: 0 },
   { $set: { largeField: "b".repeat( 16 * 1024 * 1024 - 1024 ) } }
)

largeField ahora contiene la letra repetida b.

Recupera los fragmentos de myChangeStreamCursor utilizando el método next() y almacena los fragmentos en objetos llamados firstFragment, secondFragment y thirdFragment:

const firstFragment = myChangeStreamCursor.next()
const secondFragment = myChangeStreamCursor.next()
const thirdFragment = myChangeStreamCursor.next()

Mostrar firstFragment.splitEvent:

firstFragment.splitEvent

Salida con los detalles del fragmento:

splitEvent: { fragment: 1, of: 3 }

De manera similar, secondFragment.splitEvent y thirdFragment.splitEvent devuelven:

splitEvent: { fragment: 2, of: 3 }
splitEvent: { fragment: 3, of: 3 }

Para examinar las claves de objeto para firstFragment:

Object.keys( firstFragment )

Salida:

[
   '_id',
   'splitEvent',
   'wallTime',
   'clusterTime',
   'operationType',
   'documentKey',
   'ns',
   'fullDocument'
]

Para examinar el tamaño en bytes de firstFragment.fullDocument:

bsonsize( firstFragment.fullDocument )

Salida:

16776223

secondFragment contiene la preimagen fullDocumentBeforeChange, que tiene un tamaño aproximado de 16 MB. El siguiente ejemplo muestra las claves de objeto para secondFragment:

Object.keys( secondFragment )

Salida:

[ '_id', 'splitEvent', 'fullDocumentBeforeChange' ]

thirdFragment Contiene el campo updateDescription, que ocupa aproximadamente 16 MB. El siguiente ejemplo muestra las claves de objeto para thirdFragment:

Object.keys( thirdFragment )

Salida:

[ '_id', 'splitEvent', 'updateDescription' ]

Los ejemplos de C# en esta página utilizan la base de datos sample_mflix de la conjuntos de datos de muestra de Atlas. Para aprender cómo crear un clúster gratuito de MongoDB Atlas y cargar los conjuntos de datos de muestra, consulta Primeros pasos en la documentación del controlador .NET/C# de MongoDB.

La siguiente clase Movie modela los documentos en la colección sample_mflix.movies:

public class Movie
{
    public ObjectId Id { get; set; }
    public int Runtime { get; set; }
    
    public string Title { get; set; }
    public string Rated { get; set; }
    public List<string> Genres { get; set; }
    public string Plot { get; set; }
    
    public ImdbData Imdb { get; set; }
    public int Year { get; set; }
    public int Index { get; set; }
    
    public string[] Comments { get; set; }
   
    [BsonElement("lastupdated")]
    public DateTime LastUpdated { get; set; }
}

var camelCaseConvention = new ConventionPack { new CamelCaseElementNameConvention() };
ConventionRegistry.Register("CamelCase", camelCaseConvention, type => true);

Para usar el controlador .NET/C# de MongoDB para añadir una etapa $changeStreamSplitLargeEvent a una pipeline de agregación, llama a ChangeStreamSplitLargeEvent()método en un PipelineDefinition objeto.

El siguiente ejemplo crea una etapa de pipeline que divide eventos que superan 16 MB en fragmentos y los devuelve secuencialmente en un cursor de flujo de cambios:

var pipeline = new EmptyPipelineDefinition<ChangeStreamDocument<Movie>>()
    .ChangeStreamSplitLargeEvent();

Puedes utilizar tanto el método watch() como el método aggregate() para ejecutar una operación $changeStreamSplitLargeEvent. $changeStreamSplitLargeEvent devuelve un ChangeStreamCursor cuando se pasa el pipeline de agregación al método watch() en un objeto de MongoDB Collection. $changeStreamSplitLargeEvent devuelve un AggregationCursor cuando pasas el pipeline de agregación al método aggregate().

El siguiente ejemplo divide los eventos que superan los 16 MB en fragmentos y los devuelve secuencialmente en un ChangeStreamCursor:

const pipeline = [{ changeStreamSplitLargeEvent: {} }];
const changeStream = collection.watch(pipeline);
return changeStream;