目标连接器写入模型策略
概述
您可以通过设置配置属性来指定 MongoDB Kafka 目标连接器如何将数据写入 MongoDB。以下各节描述了您可以设置的配置属性，以自定义此行为。
编写模型
设置writemodel.strategy 配置属性以指定当接收到的写入记录时，sink 连接器如何写入数据。
您可以将 writemodel.strategy 的值设置为该页面“策略”部分中描述的写入模型策略的任何完全限定类名。您可以通过设置以下配置来指定策略策略 部分。您可以通过设置以下配置来指定一个策略
writemodel.strategy=<a write model strategy>
删除写入模型
设置 delete.writemodel.strategy 配置属性以指定在接收 tombstone 事件时 sink 连接器如何写入数据。tombstone 事件是包含键但没有值的记录，表示已删除的记录。
您可以将 delete.writemodel.strategy 的值设置为该页面“策略”部分中描述的写入模型策略的任何完全限定类名。您可以通过设置以下配置来指定策略
delete.writemodel.strategy=<a write model strategy>
有关按类别组织的 sink 连接器配置设置的列表，请参阅sink 连接器配置属性指南.
策略
名称 | 描述 | |
|---|---|---|
默认写入模型策略 | 描述 此策略默认使用 ReplaceOneDefaultStrategy，如果设置了 timeseries.timefield 选项，则使用 InsertOneDefaultStrategy。这是 writemodel.strategy 配置属性的默认值。 | |
InsertOneDefaultStrategy | 描述 将每个下游记录插入MongoDB作为文档。 要指定此策略，将配置属性设置为以下类名 | |
ReplaceOneDefaultStrategy | 描述 通过 _id 字段替换MongoDB中最多一个与下游记录匹配的文档。如果没有文档匹配，连接器将下游记录作为新文档插入。要指定此策略，将配置属性设置为以下类名 | |
ReplaceOneBusinessKeyStrategy | 描述 通过指定的业务键替换最多一个与下游记录匹配的文档。如果没有文档匹配，连接器将下游记录作为新文档插入。 要指定此策略，将配置属性设置为以下类名 有关如何使用此策略的示例，请参阅我们的写入模型策略指南。 | |
DeleteOneDefaultStrategy | 描述 仅当文档包含空值结构时，通过 _id 字段删除最多一个与您的下游连接器的键结构匹配的文档。这是 delete.writemodel.strategy 配置属性的默认值。当您设置 mongodb.delete.on.null.values=true 时，此策略被设置为 writemodel.strategy 属性的默认值。要指定此策略，将配置属性设置为以下类名 | |
DeleteOneBusinessKeyStrategy | 描述 通过业务键删除最多一个与下游记录匹配的MongoDB文档。 要指定此策略，将配置属性设置为以下类名 有关如何使用此策略的示例，请参阅我们的写入模型策略指南。 | |
UpdateOneDefaultStrategy | 描述 通过 _id 字段最多更新MongoDB中的一个与下游记录匹配的文档。如果没有文档匹配，连接器将下游记录作为新文档插入。要指定此策略，将配置属性设置为以下类名 | |
UpdateOneTimestampsStrategy | 描述 将 _insertedTS（插入时间戳）和 _modifiedTS（修改时间戳）字段添加到文档中。要指定此策略，将配置属性设置为以下类名 有关如何使用此策略的示例，请参阅我们的写入模型策略指南。 | |
UpdateOneBusinessKeyTimestampStrategy | 描述 将 _insertedTS（插入时间戳）和 _modifiedTS（修改时间戳）字段添加到与业务键匹配的文档中。要指定此策略，将配置属性设置为以下类名 |