Estratégias do modelo de gravação do conector do coletor

Visão geral

Você pode definir propriedades de configuração para especificar como o de MongoDB Kafka coletor do connector grava dados no MongoDB. As seções a seguir descrevem as propriedades de configuração que você pode definir para personalizar este comportamento.

WriteModel

Configure a propriedade de configuração writemodel.strategy para especificar como o connector do coletor grava dados quando recebe um registro do coletor.

You can set the value of writemodel.strategy to any of the fully qualified class names of the write model strategies described in the Strategies section of this page. You can specify a strategy by setting the following configuration:

writemodel.strategy=<a write model strategy>

Excluir modelo de gravação

Configure a propriedade de configuração delete.writemodel.strategy para especificar como o connector do coletor grava dados quando recebe um evento de marca para exclusão. Um evento de marca de exclusão é um registro que contém uma chave, mas nenhum valor, o que significa um registro excluído.

You can set the value of delete.writemodel.strategy to any of the fully qualified class names of the write model strategies described in the Strategies section of this page. You can specify a strategy by setting the following configuration:

delete.writemodel.strategy=<a write model strategy>

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

Strategies

Nome

Descrição

DefaultWriteModelStrategy

Descrição:
Por padrão, esta estratégia usa o ReplaceOneDefaultStrategy e o InsertOneDefaultStrategy se você definir a opção timeseries.timefield.

Este é o valor padrão para a propriedade de configuração writemodel.strategy.

InsertOneDefaultStrategy

Descrição:
Insira cada registro de sink no MongoDB como um documento.
Para especificar essa estratégia, defina a propriedade de configuração para o seguinte nome de classe:

com.mongodb.kafka.connect.sink.writemodel.strategy.InsertOneDefaultStrategy

ReplaceOneDefaultStrategy

Descrição:
Substitui no máximo um documento no MongoDB que corresponde a um registro de sink pelo campo _id. Se nenhum documento corresponder, o conector inserirá o registro de sink como um novo documento.
Para especificar essa estratégia, defina a propriedade de configuração para o seguinte nome de classe:

com.mongodb.kafka.connect.sink.writemodel.strategy.ReplaceOneDefaultStrategy

Substituir uma estratégia-chave de negócio

Descrição:
Substitui no máximo um documento que corresponde a um registro de sink por uma chave comercial especificada. Se nenhum documento corresponder, o conector inserirá o registro de sink como um novo documento.
Para especificar essa estratégia, defina a propriedade de configuração para o seguinte nome de classe:

com.mongodb.kafka.connect.sink.writemodel.strategy.ReplaceOneBusinessKeyStrategy

Para ver um exemplo mostrando como usar essa estratégia, consulte nosso guia sobre estratégias de modelo de gravação.

DeleteOneDefaultStrategy

Descrição:
Exclui no máximo um documento que corresponda à estrutura de chave do seu conector de coletor pelo campo _id somente quando o documento contiver uma estrutura de valor nulo.

Este é o valor padrão para a propriedade de configuração delete.writemodel.strategy.

Essa estratégia é definida como o valor padrão da propriedade writemodel.strategy quando você define delete.on.null.values=true.
Para especificar essa estratégia, defina a propriedade de configuração para o seguinte nome de classe:

com.mongodb.kafka.connect.sink.writemodel.strategy.DeleteOneDefaultStrategy

Excluir uma estratégia de chave de negócios

Descrição:
Exclui no máximo um documento MongoDB que corresponde a um registro coletor por uma chave comercial. Essa estratégia exige um valueDoc para geração de chaves. Para aproveitar o PartialKeyStrategy para geração de chaves, use o DeleteOneTombstoneBusinessKeyStrategy.

Para especificar essa estratégia, defina a propriedade de configuração para o seguinte nome de classe:

com.mongodb.kafka.connect.sink.writemodel.strategy.DeleteOneBusinessKeyStrategy

Para ver um exemplo mostrando como usar essa estratégia, consulte nosso guia sobre estratégias de modelo de gravação.

DeleteOneTombstoneBusinessKeyStrategy

Descrição:
Exclui no máximo um documento MongoDB que corresponde a um registro coletor por uma chave comercial. Essa estratégia aproveita o PartialKeyStrategy para criar a chave usada para exclusão.

Para especificar essa estratégia, defina a propriedade de configuração para o seguinte nome de classe:

com.mongodb.kafka.connect.sink.writemodel.strategy.DeleteOneTombstoneBusinessKeyStrategy

UpdateOneDefaultStrategy

Descrição:
Atualiza no máximo um documento no MongoDB que corresponde a um registro de coletor pelo campo _id. Se nenhum documento corresponder, o conector inserirá o registro de sink como um novo documento.
Para especificar essa estratégia, defina a propriedade de configuração para o seguinte nome de classe:

com.mongodb.kafka.connect.sink.writemodel.strategy.UpdateOneDefaultStrategy

Atualizar estratégia de carimbos de data/hora

Descrição:
Adicione os campos _insertedTS (carimbo de data/hora inserido) e _modifiedTS (carimbo de data/hora modificado) aos documentos.
Para especificar essa estratégia, defina a propriedade de configuração para o seguinte nome de classe:

com.mongodb.kafka.connect.sink.writemodel.strategy.UpdateOneTimestampsStrategy

Para ver um exemplo mostrando como usar essa estratégia, consulte nosso guia sobre estratégias de modelo de gravação.

UpdateOne BusinessKeyTimestampStrategy

Descrição:
Adicione _insertedTS (carimbo de data/hora inserido) e _modifiedTS (carimbo de data/hora modificado) campos em documentos que correspondem a uma chave comercial.
Para especificar essa estratégia, defina a propriedade de configuração para o seguinte nome de classe:

com.mongodb.kafka.connect.sink.writemodel.strategy.UpdateOneBusinessKeyTimestampStrategy

Voltar

Estratégia de ID

Substituição de tópico