Para agentes de IA: hay un índice de documentación disponible en https://www.mongodb.com/es/docs/llms.txt — versiones en markdown de todas las páginas están disponibles agregando .md a cualquier ruta URL.
Make the MongoDB docs better! We value your opinion. Share your feedback for a chance to win $100.
MongoDB Branding Shape
Click here >
Docs Menu

Cambiar Propiedades del Stream

Utiliza la siguiente configuración para especificar pipelines de agregación para flujos de cambios y preferencias de lectura para cursores de flujos de cambios cuando trabajes con el conector fuente MongoDB Kafka.

Para obtener una lista de la configuración del origen del conector organizadas por categoría, consulta la guía Propiedades de configuración del conector de origen.

Nombre
Descripción

pipeline

Tipo: cadena

Descripción:
Una matriz de canalizaciones de agregación para ejecutar en su flujo de cambios. Debe configurar este ajuste para el documento de evento del flujo de cambios, no para el fullDocument campo.

Por ejemplo:

[{"$match": { "$and": [{"operationType": "insert"}, {"fullDocument.eventId": 1404 }] } }]

Para ver más ejemplos, consulte:

Predeterminado: "[]"
Valores aceptados: Etapa válida de la canalización de agregación

flujo de cambios.full.documento

Tipo: cadena

Descripción:
Determina

los valores que devuelve el flujo de cambios en las operaciones de actualización. La configuración predeterminada devuelve las diferencias entre el documento original y el documento actualizado.

La updateLookup configuración devuelve las diferencias entre el documento original y el documento actualizado, así como una copia del documento actualizado completo en un momento posterior a la actualización.

La whenAvailable configuración devuelve el documento actualizado, si está disponible.

La required configuración devuelve el documento actualizado y genera un error si no está disponible.

Para obtener más información sobre cómo funciona esta opción de flujo de cambios, consulte "Buscar documento completo para operaciones de actualización" en el manual de MongoDB.

Predeterminado: ""
Valores ""aceptados:,, "updateLookup" "whenAvailable"o "required"

cambiar.transmisión.mostrar.eventos.expandidos

Tipo: booleano

Descripción:
Determina si los flujos de cambios notifican eventos DDL como
createIndexes y

dropIndexes. Para obtener más información, consulte showExpandedEvents.

Esta configuración es necesaria para mostrar
updateDescription.disambiguatedPaths en los eventos de actualización, lo que
aclara los cambios que involucran campos ambiguos. Para obtener más información,
consulte disambiguatedPaths.

false
Valor predeterminado: Valores aceptados: true o false

flujo.de.cambios.full.documento.before.change

Tipo: cadena

Descripción:
Configura la preimagen del documento que devuelve el flujo de cambios en las operaciones de actualización. La preimagen no está disponible para los registros de origen publicados al copiar datos existentes, y la configuración de la preimagen no afecta a la copia.

Para obtener información sobre cómo configurar una colección para habilitar las preimágenes, consulte Flujos de cambios con preimágenes y posimágenes de documentos en el manual de MongoDB.

La configuración predeterminada suprime la preimagen del documento.

La configuración devuelve whenAvailable la preimagen del documento si está disponible, antes de que se haya reemplazado, actualizado o eliminado.

La required configuración devuelve la preimagen del documento y genera un error si no está disponible.

Predeterminado: ""
Valores aceptados: "" o "whenAvailable" o "required"

publish.full.document.only

Tipo: booleano

Descripción:
Indica si se debe devolver solo el fullDocument campo del documento de evento de flujo de cambios producido por cualquier evento de actualización. El fullDocument campo contiene la versión más reciente del documento actualizado. Para obtener más información sobre el fullDocument campo, consulte el evento de actualización en el manual del servidor.

Cuando se establece true en, el conector anula la configuración change.stream.full.document y ​​la establece en updateLookup para que el fullDocument campo contenga los documentos actualizados.

false
Valor predeterminado: Valores aceptados: true o false

Solo document completo (tumba) al borrar

Tipo: booleano

Descripción:
Indica si se deben devolver eventos de eliminación cuando se borran documentos. Los eventos de eliminación contienen las claves de los documentos eliminados con null valores. Esta configuración solo se aplica publish.full.document.only cuando true es.

false
Valor predeterminado: Valores aceptados: true o false

flujo de cambios.documento.key.as.key

Tipo: booleano

Descripción:
Indica si se debe usar la clave del documento como clave del registro de origen si la clave del documento está presente.

Si se establece true en, el conector agrega las claves de los documentos eliminados a los eventos de eliminación. Si se establece false en, el conector usa el token de reanudación como clave de origen para los eventos de eliminación.

true
Valor predeterminado: Valores aceptados: true o false

intercalación

Tipo: cadena

Descripción:
Un documento de intercalación JSON que especifica las reglas de ordenación específicas del idioma que MongoDB aplica a los documentos devueltos por el flujo de cambios.

""
Valor predeterminado: Valores aceptados: Un documento JSON de intercalación válido

batch.size

Tipo: int

Descripción:
Tamaño del lote del cursor de flujo de cambios.

0
Valor predeterminado: Valores aceptados: Un número entero

poll.await.time.ms

Tipo: long

Descripción:
El tiempo máximo en milisegundos que el servidor espera a que se informen nuevos cambios de datos al cursor del flujo de cambios antes de devolver un lote vacío.

5000
Valor predeterminado: Valores aceptados: Un número entero

poll.max.batch.size

Tipo: int

Descripción:
Número máximo de documentos a leer en un solo lote al consultar un cursor de flujo de cambios para obtener nuevos datos. Puede usar esta configuración para limitar la cantidad de datos almacenados internamente en el conector.

Valor predeterminado: 1000
Valores aceptados: Un número entero