MongoDbAtlasSink Class

A copy activity MongoDB Atlas sink.

Constructor

MongoDbAtlasSink(*args: Any, **kwargs: Any)

Variables

Name Description
write_batch_size
any

Write batch size. Type: integer (or Expression with resultType integer), minimum: 0.

write_batch_timeout
any

Write batch timeout. Type: string (or Expression with resultType string), pattern: ((d+).)?(dd):(60|([0-5][0-9])):(60|([0-5][0-9])).

sink_retry_count
any

Sink retry count. Type: integer (or Expression with resultType integer).

sink_retry_wait
any

Sink retry wait. Type: string (or Expression with resultType string), pattern: ((d+).)?(dd):(60|([0-5][0-9])):(60|([0-5][0-9])).

max_concurrent_connections
any

The maximum concurrent connection count for the sink data store. Type: integer (or Expression with resultType integer).

disable_metrics_collection
any

If true, disable data store metrics collection. Default is false. Type: boolean (or Expression with resultType boolean).

write_behavior
any

Specifies whether the document with same key to be overwritten (upsert) rather than throw exception (insert). The default value is "insert". Type: string (or Expression with resultType string). Type: string (or Expression with resultType string).

type
str

Copy sink type. Required. Default value is "MongoDbAtlasSink".

Attributes

type

Copy sink type. Required. Default value is "MongoDbAtlasSink".

type: Literal['MongoDbAtlasSink']

write_behavior

Specifies whether the document with same key to be overwritten (upsert) rather than throw exception (insert). The default value is "insert". Type: string (or Expression with resultType string). Type: string (or Expression with resultType string).

write_behavior: Any | None