Propiedades de empresa emergente

empresa emergente.moda

Tipo: string

descripción:
Especifica cómo debe iniciarse el conector cuando no hay un source offset disponible. Para reanudar un flujo de cambios se necesita un resume token, que el conector obtiene del source offset. Si no hay un source offset disponible, el conector puede ignorar todos o algunos de los datos de origen existentes, o puede copiar primero todos los datos de origen existentes y luego continuar con el procesamiento de datos nuevos.

Si startup.mode=latest, el conector ignora todos los datos de origen existentes.

Si startup.mode=timestamp, el conector activa las propiedades startup.mode.timestamp.*. Si no se configura ninguna propiedad, timestamp es equivalente a latest.

Si startup.mode=copy_existing, el conector copia todos los datos de origen existentes en los eventos de flujo de cambios. Esta configuración es equivalente a la configuración obsoleta copy.existing=true.

Si algún sistema cambia los datos en la base de datos mientras el conector de origen convierte los datos existentes de ella, MongoDB puede producir eventos de flujo de cambios duplicados para reflejar los últimos cambios. Dado que los eventos de flujo de cambios de los que depende la copia de datos son idempotentes, los datos copiados son eventualmente coherentes, lo que se ajusta a una garantía de entrega "al menos una vez".

por defecto:latest
Valores aceptados: latest, timestamp, copy_existing

startup.mode.timestamp.start.at.operación.time

Tipo: string

Descripción:
Se activa solo si startup.mode=timestamp. Especifica el punto de inicio para el flujo de cambios.

Para obtener más información sobre los parámetros de Change Stream, consulte $changeStream (agregación) en el manual de MongoDB.

Por defecto: ""
Valores aceptados:

• Un número entero de segundos transcurridos desde la Unix epoch en formato decimal (por ejemplo, 30)

• Un instante en el formato ISO-8601 con una precisión de un segundo (por ejemplo, 1970-01-01T00:00:30Z)

• Una marca de tiempo BSON en el formato JSON extendido canónico (v2) (por ejemplo, {"$timestamp": {"t": 30, "i": 0}})

Regex de Modo de startup.copy.existing.namespace.regex

Tipo: string

descripción:
expresión regular que el conector utiliza para hacer coincidir namespace desde los que copiar datos. Un namespace describe el nombre de la base de datos de MongoDB y la colección separados por un punto (por ejemplo, databaseName.collectionName).

Por ejemplo, la siguiente configuración de expresión regular hace coincidir colecciones que comienzan con "page" en la base de datos stats:

startup.mode.copy.existing.namespace.regex=stats\.page.*

El carácter \ en el ejemplo anterior escapa el carácter . que le sigue en la expresión regular. Para obtener más información sobre cómo compilar expresiones regulares, consulte patrón en la documentación de la API de Java.

Por defecto: ""
Valores aceptados: Una expresión regular válida

startup.mode.copy.existing.pipeline

Tipo: string

descripción:
Un arreglo en línea de operaciones de pipeline que el conector ejecuta al copiar datos existentes. Puede utilizar esta configuración para filtro la colección de origen y mejorar el uso de los índices en el proceso de copia.

Por ejemplo, la siguiente configuración utiliza el $match operador de agregación para indicar al conector que copie solo los documentos que contengan un campo closed con un valor de false.

startup.mode.copy.existing.pipeline=[ { "$match": { "closed": "false" } } ]

Por defecto: ""
Valores aceptados: etapas válidas del pipeline de agregación

startup.mode.copy.existing.max.threads

Tipo: int

descripción:
El número máximo de subprocesos que el conector puede usar para copiar datos.

Por defecto: número de procesadores disponibles en el entorno
Valores aceptados: Un número entero

startup.mode.copy.existing.queue.size

Tipo: int

Descripción:
El tamaño de la cola que el conector puede usar al copiar datos.

por defecto: 16000
Valores aceptados: Un número entero

Permitir el uso de disco para copiar datos existentes

Tipo: booleano

Descripción:
Cuando se establece en true, el conector utiliza almacenamiento temporal en disco para copiar la agregación existente.

Por defecto: true
Valores aceptados: true o false