Para agentes de IA: um índice de documentação está disponível em https://www.mongodb.com/pt-br/docs/llms.txt — as versões de markdown de todas as páginas estão disponíveis anexando .md a qualquer caminho de URL.
Menu Docs

Propriedades de inicialização

Use as seguintes definições de configuração para configurar a inicialização do conector de origem MongoDB Kafka para converter coleções MongoDB em Alterar eventos de Stream.

Dica

Para obter um exemplo usando a funcionalidade copiar dados existentes, consulte o Exemplo de uso de Copiar dados existentes .

Para obter uma lista de definições de configuração do conector de origem organizadas por categoria, consulte o guia sobre Propriedades de configuração do conector de origem.

Nome
Descrição

startup.mode

Tipo: string

Descrição:
Especifica como o conector deve ser iniciado quando não houver deslocamento de origem disponível. A retomada de um fluxo de alterações requer um token de retomada, que o conector obtém do deslocamento de origem. Se nenhuma compensação de origem estiver disponível, o conector poderá ignorar todos ou alguns dos dados de origem existentes ou poderá, em um primeiro momento, copiar todos os dados de origem existentes e, em seguida, continuar em processamento de novos dados.

Se startup.mode=latest, o conector ignorará todos os dados de origem existentes.

Se startup.mode=timestamp, o conector aciona propriedades startup.mode.timestamp.*. Se nenhuma propriedade for configurada, timestamp é equivalente a latest.

Se startup.mode=copy_existing, o conector copia todos os dados de origem existentes para eventos do Change Stream. Esta configuração é equivalente à configuração preterida copy.existing=true.

Se algum sistema alterar os dados no banco de dados enquanto o conector de origem converte os dados existentes dele, o MongoDB poderá produzir eventos de fluxo de mudança duplicados para refletir as alterações mais recentes. Como os eventos de fluxo de alterações nos quais a cópia de dados depende são idempotentes, os dados copiados são eventualmente consistentes, em conformidade com uma garantia de entrega "pelo menos uma vez".

Padrão:latest
Valores aceitos: latest, timestamp, copy_existing

startup.mode.timestamp.start.at.operation.time

Type: string

Description:
Actuated only if startup.mode=timestamp. Specifies the starting point for the change stream.

To learn more about Change Stream parameters, see $changeStream (aggregation) in the MongoDB manual.

Default: ""
Accepted Values:

  • Um número inteiro de segundos desde a época no formato decimal (por exemplo, 30)

  • Um instante no formato ISO-8601 com uma segunda precisão (por exemplo, 1970-01-01T00:00:30Z)

  • Um carimbo de data/hora JSON no formato JSON estendido canônico (v2) (por exemplo, {"$timestamp": {"t": 30, "i": 0}})

startup.mode.copy.existing.namespace.regex

Tipo: string

Descrição:
Expressão regular que o conector usa para corresponder aos namespaces dos quais copiar dados. Um namespace descreve o nome do banco de dados MongoDB e a coleção separados por um período (por exemplo, databaseName.collectionName).

Por exemplo, a seguinte configuração de expressão regular corresponde às coleções que começam com "page" no banco de dados stats:

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

O caractere \ no exemplo acima escapa o caractere . que o segue na expressão regular. Para obter mais informações sobre como criar expressões regulares, consulte Padrões na documentação da API Java.

Padrão: ""
Valores aceitos: uma expressão regular válida

startup.mode.copy.existing.pipeline

Type: string

Description:
An inline array of pipeline operations the connector runs when copying existing data. You can use this setting to filter the source collection and improve the use of indexes in the copying process.

For example, the following setting uses the $match aggregation operator to instruct the connector to copy only documents that contain a closed field with a value of false.

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

Padrão: ""
Valores aceitos: fases do pipeline de agregação válidas

startup.mode.copy.existing.max.threads

Tipo: int

Descrição:
O número máximo de threads que o conector pode usar para copiar dados.

Padrão: número de processadores disponíveis no ambiente
Valores aceitos: um número inteiro

startup.mode.copy.existing.queue.size

Tipo: int

Descrição:
O tamanho da fila que o conector pode usar ao copiar dados.

Padrão: 16000
Valores aceitos: um número inteiro

startup.mode.copy.existing.allow.disk.use

Tipo: booleano

descrição:
Quando definido como true, o conector usa armazenamento temporário em disco para a agregação de cópia existente.

padrão: true
Valores aceitos: true ou false

Avalie esta página