スタートアップ プロパティ

startup.mode

タイプ: string

説明:
ソース オフセットが利用できない場合にコネクターが起動する方法を指定します。変更ストリームを再開するにはレジュームトークンが必要で、コネクタはこのレジュームトークンをソースオフセットから取得します。ソース オフセットが利用できない場合、コネクタは既存のソース データのすべてまたは一部を無視することができます。または、最初にすべての既存のソース データをコピーして、その後、新しいデータのプロセシングを続行することができます。

startup.mode=latest の場合、コネクタはすべての既存のソース データを無視します。

startup.mode=timestamp の場合、コネクターは startup.mode.timestamp.* つのプロパティを作動させます。プロパティが設定されていない場合、timestamp は latest と同等です。

もし startup.mode=copy_existing の場合、コネクターは存在するすべてのソース データを Change Stream イベントにコピーします。この設定は、非推奨の設定 copy.existing=true と同等です。

ソースコネクタが既存のデータを変換するときに、いずれかのシステムがデータベース内のデータを変更した場合、 MongoDB は最新の変更を反映するために重複した変更ストリームイベントを生成することがあります。データコピーが依存する変更ストリームイベントが冪等であるため、コピーされたデータは結果整合性があり、"少なくとも 1 回" の配信保証に準拠します。

デフォルト:latest
許容値: 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:

• 10進数形式での UNIXエポックからの整数（例: 30 ）

• 1 秒の精度を持つ ISO-8601 形式のインスタンス（例: 1970-01-01T00:00:30Z ）

• 標準拡張 JSON（v2）形式の BSON タイムスタンプ（例: {"$timestamp": {"t": 30, "i": 0}} ）

startup.mode. copy.existing.namespace.regex

型: string

説明:
コネクターが使用する正規式で、データのコピー元となる名前空間と一致させます。名前空間は、MongoDB データベース名とコレクションをピリオドで区切って記述します (例: databaseName.collectionName)。

例えば、次の正規式設定は、stats データベース内の "page" で始まるコレクションに一致します。

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

上記の例の \ 文字は、正規式でその後に続く . 文字をエスケープします。正規式のビルドする方法の詳細については、Java API ドキュメントの「パスワードなし」を参照してください。

デフォルト: ""
許容値: 有効な正規式

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" } } ]

デフォルト: ""
受け入れられる値: 有効な集計パイプライン ステージ

startup.mode. copy.existing.max.threads

型: int

説明:
コネクタがデータのコピーに使用できるスレッドの最大数。

デフォルト: 環境内で利用可能なプロセッサの数
許容値: 整数

startup.mode. copy.existing.queue.size

型: int

説明:
データのコピー時にコネクタが使用できるキューのサイズ。

デフォルト: 16000
許容値: 整数

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

タイプ: ブール値

説明:
true に設定すると、コネクタは既存の集計をコピーするために一時ディスク ストレージを使用します。

デフォルト: true
許容される値: true または false