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

Cree un cursor de flujo de cambios para monitorear los cambios en myCollection db.collection.watch()usando:

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

Para el evento de flujo de cambio:

• fullDocument: "required" Incluye la imagen posterior del documento.

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

Para obtener más detalles, consulte $changeStream.

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

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

largeField ahora contiene la letra repetida b.

Recupere los fragmentos de myChangeStreamCursor utilizando el método y almacene los fragmentos en next() objetos firstFragment llamados, secondFragment thirdFragmenty:

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 tiene un tamaño aproximado de 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 Conjuntos de datos de ejemplo de Atlas. Para aprender a crear un clúster gratuito de MongoDB Atlas y cargar los conjuntos de datos de ejemplo,consulte "Comenzar" en la documentación del controlador MongoDB.NET/C#.

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 MongoDB.NET/C# para agregar una $changeStreamSplitLargeEvent etapa a una canalización de agregación, llame 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();

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

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

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