Propriedades de inicialização

startup.mode

Tipo: string

Descrição:
especifica como o conector deve ser iniciado quando não houver nenhum deslocamento de origem disponível. A retomada de um change stream 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 com o processamento de novos dados.

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

startup.mode=timestampSe, o conector aciona startup.mode.timestamp.* propriedades. Se nenhuma propriedade estiver configurada, timestamp será equivalente latest a.

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

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 latestaceitos:,, timestampcopy_existing

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

Tipo: string


startup.mode=timestamp



Descrição: ""
Acionado somente se. Especifica o ponto de partida para o fluxo de alteração. Para saber mais sobre como alterar os parâmetros do stream, consulte $changeStream (agregação) no manual do MongoDB . Padrão: Valores aceitos:

• 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 (pordatabaseName.collectionName exemplo,).

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

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

O \ caractere no exemplo acima escapa do . 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

Tipo: string

Descrição:
uma array em linha de operações de pipeline que o conector executa ao copiar dados existentes. Você pode usar essa configuração para filtrar a collection de origem e melhorar o uso de índices no processo de cópia.

Por exemplo, a configuração a seguir usa o operador de agregação $match para instruir o conector a copiar somente documentos que contenham um closed campo com um valor false de.

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

""
Padrão:Valores aceitos: estágios de pipeline de agregação válidos

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 true como, o conector usa armazenamento em disco temporário para copiar a agregação existente.

Padrão: true
Valores aceitos: true ou false