/ /

Sink Connector 書込みモデル戦略

Overview

構成プロパティを設定して、MongoDB Kafka Sink Connector が MongoDB にデータを書込む方法を指定できます。次のセクションでは、この動作をカスタマイズするために設定できる構成プロパティについて説明します。

書込みモデル

Sink Connector が Sink レコードを受信したときにデータを書込む方法を指定するには、 writemodel.strategy構成プロパティを設定します。

writemodel.strategyの値は、このページの「戦略」セクションで説明されている書込みモデル戦略の完全修飾クラス名のいずれかに設定できます。次の構成を設定することで、戦略を指定できます。

writemodel.strategy=<a write model strategy>

書込みモデルの削除

Sink Connector がトゥームストーンイベントを受信したときにデータを書き込む方法を指定するには、 delete.writemodel.strategy構成プロパティを設定します。トゥームストーンイベントとは、キーを含むが値は含まないレコードであり、削除されたレコードを意味します。

delete.writemodel.strategyの値は、このページの「戦略」セクションで説明されている書込みモデル戦略の完全修飾クラス名のいずれかに設定できます。次の構成を設定することで、戦略を指定できます。

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

カテゴリ別に整理された Sink Connector 構成設定のリストについては、「 Sink Connector 構成プロパティ」に関するガイドを参照してください。

Strategies

名前

説明

DefaultWriteModelStratey

説明:
この戦略では、デフォルトではReplaceOneDefaultStrategy InsertOneDefaultStrategytimeseries.timefield

が使用され、writemodel.strategy オプションを設定するとが使用されます。これは、構成プロパティのデフォルト値です。

InsertOneDefaultStrategy

説明:
各 SinkレコードをドキュメントとしてMongoDBに挿入します。この戦略を指定するには、
構成プロパティを次のクラス名に設定します。

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

ReplaceOneDefaultStratey

説明:
MongoDB内のドキュメントのうち、sinkレコードと一致するものを_id
フィールドに置き換えます。一致するドキュメントがない場合、コネクタはSinkレコードを新しいドキュメントとして挿入します。この戦略を指定するには、構成プロパティを次のクラス名に設定します。

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

ReplaceOne BusinessKeyStratey

説明:
指定されたビジネスキーで Sinkレコードに一致するドキュメントを最大 1
つ置き換えます。一致するドキュメントがない場合、コネクタはSinkレコードを新しいドキュメントとして挿入します。この戦略を指定するには、構成プロパティを次のクラス名に設定します。

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

この戦略の使用方法を示す例えについては、書込みモデル戦略に関するガイドを参照してください。

DeleteOneDefaultStratey

説明:ドキュメントに null 値構造が含まれている場合にのみ、フィールドによって
Sink Connector のキー構造と一致するドキュメントを最大 1 つ削除します。これは、_id

delete.writemodel.strategy

構成プロパティのデフォルト値です。この戦略は、を設定するときにプロパティのデフォルト値として設定されます。この戦略を指定するには、writemodel.strategy delete.on.null.values=true
構成プロパティを次のクラス名に設定します。

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

DeleteOne BusinessKeyStratey

説明:
ビジネスキーで Sinkレコードに一致するMongoDBドキュメントを最大 1 つ削除します。この戦略では、キー生成にvalueDoc が必要です。キー生成にPartialKeyStrategy を活用するには、を使用します。この戦略を指定するには、DeleteOneTombstoneBusinessKeyStrategy

構成プロパティを次のクラス名に設定します。

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

この戦略の使用方法を示す例えについては、書込みモデル戦略に関するガイドを参照してください。

DeleteOneTomsKeyStratey

説明:
ビジネスキーで Sinkレコードに一致するMongoDBドキュメントを最大 1 つ削除します。この戦略では、を活用して、削除に使用されるキーを作成します。この戦略を指定するには、PartialKeyStrategy

構成プロパティを次のクラス名に設定します。

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

UpdateOneDefaultStrategy

説明:
フィールドによって Sinkレコードに一致するMongoDB内の最大 1_id つのドキュメントを更新します。一致するドキュメントがない場合、コネクタはSinkレコードを新しいドキュメントとして挿入します。この戦略を指定するには、
構成プロパティを次のクラス名に設定します。

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

UpdateOneTimestampsStratey

説明:
_insertedTS（挿入タイムスタンプ）と_modifiedTS （変更タイムスタンプ）フィールドをドキュメントに追加します。この戦略を指定するには、
構成プロパティを次のクラス名に設定します。

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

この戦略の使用方法を示す例えについては、書込みモデル戦略に関するガイドを参照してください。

UpdateOne BusinessKeyTimestampStratey

説明:ビジネスキーに一致するドキュメントに
_insertedTS（挿入タイムスタンプ）と（変更タイムスタンプ）フィールドを追加します。この戦略を指定するには、_modifiedTS 構成プロパティを次のクラス名に設定します。

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

戻る

ID 戦略

トピックの上書き