DatasourceFlowsUpdateDataflowConfig

pydantic model openapi_client.models.datasource_flows_update_dataflow_config.DatasourceFlowsUpdateDataflowConfig

Updated type-specific configuration for the dataflow.

Fields:

• additional_task_settings (Dict[str, Any] | None)

• advanced_filters (str | None)

• allocated_storage (openapi_client.models.datasource_flows_details_dataflow_config_allocated_storage.DatasourceFlowsDetailsDataflowConfigAllocatedStorage | None)

• api_version (str | None)

• cdc_start_time (str | None)

• cdc_stop_position (str | None)

• consumer_configuration (openapi_client.models.datasource_flows_update_dataflow_config_consumer_configuration.DatasourceFlowsUpdateDataflowConfigConsumerConfiguration | None)

• data_transformation_configuration (openapi_client.models.datasource_flows_update_dataflow_config_data_transformation_configuration.DatasourceFlowsUpdateDataflowConfigDataTransformationConfiguration | None)

• enable_data_validation (bool | None)

• entity_id (str | None)

• entity_name (str | None)

• extra_connection_attributes (str | None)

• iceberg_table_options (openapi_client.models.datasource_flows_update_dataflow_config_iceberg_table_options.DatasourceFlowsUpdateDataflowConfigIcebergTableOptions | None)

• incremental_pull_config (str | None)

• instance_az (str | None)

• instance_class (str | None)

• instance_multi_az (bool | None)

• is_data_transformation_enabled (bool | None)

• max_dcu (int | None)

• min_dcu (int | None)

• multi_az (bool | None)

• replication_az (str | None)

• serverless_replication (bool | None)

• shared_cluster (str | None)

• shared_instance (str | None)

• sink_connector_config (Dict[str, str] | None)

• source_connector_config (Dict[str, str] | None)

• source_connector_properties (openapi_client.models.datasource_flows_update_dataflow_config_source_connector_properties.DatasourceFlowsUpdateDataflowConfigSourceConnectorProperties | None)

• source_extra_connection_attributes (str | None)

• sync_to_s3 (str | None)

• table_mappings (openapi_client.models.datasource_flows_details_dataflow_config_table_mappings.DatasourceFlowsDetailsDataflowConfigTableMappings | None)

• target_table_prep_mode (str | None)

• task_retry_config (openapi_client.models.datasource_flows_update_dataflow_config_task_retry_config.DatasourceFlowsUpdateDataflowConfigTaskRetryConfig | None)

• task_s3_payload (str | None)

• task_s3_payload_path (str | None)

• tasks (List[openapi_client.models.app_flow_task.AppFlowTask] | None)

• trigger_properties (openapi_client.models.datasource_flows_update_dataflow_config_trigger_properties.DatasourceFlowsUpdateDataflowConfigTriggerProperties | None)

• trigger_type (str | None)

field advanced_filters: Optional[StrictStr] = None (alias 'AdvancedFilters')

Advanced filtering configuration for ArcGIS items in base64 encoded string

field shared_instance: Optional[StrictStr] = None (alias 'SharedInstance')

Whether the dataflow uses a shared DMS replication instance. yes or no for JDBC Bulkload datasources.

field sync_to_s3: Optional[StrictStr] = None (alias 'SyncToS3')

Whether data is also synced to S3 for JDBC Bulkload datasources. yes or no.

field extra_connection_attributes: Optional[StrictStr] = None (alias 'ExtraConnectionAttributes')

Extra connection attributes for the DMS target endpoint.

field source_extra_connection_attributes: Optional[StrictStr] = None (alias 'SourceExtraConnectionAttributes')

Extra connection attributes for the DMS source endpoint.

field target_table_prep_mode: Optional[StrictStr] = None (alias 'TargetTablePrepMode')

How target tables are prepared.

field cdc_start_time: Optional[StrictStr] = None (alias 'CdcStartTime')

CDC start time for the replication task.

field cdc_stop_position: Optional[StrictStr] = None (alias 'CdcStopPosition')

CDC stop position for the replication task.

field instance_class: Optional[StrictStr] = None (alias 'InstanceClass')

DMS replication instance class for a dedicated instance.

field allocated_storage: Optional[DatasourceFlowsDetailsDataflowConfigAllocatedStorage] = None (alias 'AllocatedStorage')

field instance_az: Optional[StrictStr] = None (alias 'InstanceAZ')

Availability zone for a dedicated DMS replication instance.

field instance_multi_az: Optional[StrictBool] = None (alias 'InstanceMultiAZ')

Whether the dedicated DMS replication instance is multi-AZ.

field task_retry_config: Optional[DatasourceFlowsUpdateDataflowConfigTaskRetryConfig] = None (alias 'TaskRetryConfig')

field additional_task_settings: Optional[Dict[str, Any]] = None (alias 'AdditionalTaskSettings')

Additional DMS task settings for the dataflow.

field table_mappings: Optional[DatasourceFlowsDetailsDataflowConfigTableMappings] = None (alias 'TableMappings')

field task_s3_payload: Optional[StrictStr] = None (alias 'TaskS3Payload')

Whether a large task payload is stored in S3 instead of inline. yes or no.

field entity_id: Optional[StrictStr] = None (alias 'EntityId')

ID of the shared instance or shared cluster entity.

field entity_name: Optional[StrictStr] = None (alias 'EntityName')

Name of the shared instance or shared cluster entity.

field serverless_replication: Optional[StrictBool] = None (alias 'ServerlessReplication')

Whether DMS Serverless is used instead of a provisioned instance.

field max_dcu: Optional[StrictInt] = None (alias 'MaxDCU')

Maximum DMS Serverless capacity units.

field min_dcu: Optional[StrictInt] = None (alias 'MinDCU')

Minimum DMS Serverless capacity units.

field multi_az: Optional[StrictBool] = None (alias 'MultiAZ')

Whether the serverless replication is multi-AZ.

field replication_az: Optional[StrictStr] = None (alias 'ReplicationAZ')

Availability zone for serverless replication.

field task_s3_payload_path: Optional[StrictStr] = None (alias 'TaskS3PayloadPath')

Temporary S3 key of the large task payload uploaded via the GET get-presigned-url action when TaskS3Payload is yes.

field enable_data_validation: Optional[StrictBool] = None (alias 'EnableDataValidation')

Whether DMS data validation is enabled for JDBC Bulkload datasources. Not supported for Redshift serverless targets.

field iceberg_table_options: Optional[DatasourceFlowsUpdateDataflowConfigIcebergTableOptions] = None (alias 'IcebergTableOptions')

field consumer_configuration: Optional[DatasourceFlowsUpdateDataflowConfigConsumerConfiguration] = None (alias 'ConsumerConfiguration')

field is_data_transformation_enabled: Optional[StrictBool] = None (alias 'IsDataTransformationEnabled')

Whether data transformation is enabled for Streams datasources.

field data_transformation_configuration: Optional[DatasourceFlowsUpdateDataflowConfigDataTransformationConfiguration] = None (alias 'DataTransformationConfiguration')

field trigger_type: Optional[StrictStr] = None (alias 'TriggerType')

How the SaaS datasource flow is triggered. Supported values are ondemand, scheduled, and event. Event cannot be switched to or from scheduled or ondemand on update.

field trigger_properties: Optional[DatasourceFlowsUpdateDataflowConfigTriggerProperties] = None (alias 'TriggerProperties')

field api_version: Optional[StrictStr] = None (alias 'ApiVersion')

API version used by the SaaS datasource connector. Editable on update.

field incremental_pull_config: Optional[StrictStr] = None (alias 'IncrementalPullConfig')

Datetime field name used for incremental pull on scheduled SaaS flows. Editable on update when TriggerType is scheduled. Removed when TriggerType is ondemand.

field tasks: Optional[List[AppFlowTask]] = None (alias 'Tasks')

Field mapping tasks for SaaS AppFlow flows. Editable on SaaS update. Allowed taskType values are Arithmetic, Filter, Map, Map_all, Mask, Merge, Truncate, and Validate.

field shared_cluster: Optional[StrictStr] = None (alias 'SharedCluster')

Whether the dataflow uses a shared MSK Connect cluster. yes or no for JDBC Advanced Load datasources.

field source_connector_properties: Optional[DatasourceFlowsUpdateDataflowConfigSourceConnectorProperties] = None (alias 'SourceConnectorProperties')

field source_connector_config: Optional[Dict[str, StrictStr]] = None (alias 'SourceConnectorConfig')

Extra Kafka Connect source connector properties for JDBC Advanced Load datasources. String keys and string values only. Platform-managed keys cannot be set here.

field sink_connector_config: Optional[Dict[str, StrictStr]] = None (alias 'SinkConnectorConfig')

Extra Kafka Connect sink connector properties for JDBC Advanced Load datasources. String keys and string values only. Platform-managed keys cannot be set here.

to_str()

Returns the string representation of the model using alias

Return type:

str

to_json()

Returns the JSON representation of the model using alias

Return type:

str

classmethod from_json(json_str)

Create an instance of DatasourceFlowsUpdateDataflowConfig from a JSON string

Return type:

Optional[Self]

to_dict()

Return the dictionary representation of the model using alias.

This has the following differences from calling pydantic’s self.model_dump(by_alias=True):

• None is only added to the output dict for nullable fields that were set at model initialization. Other fields with value None are ignored.

Return type:

Dict[str, Any]

classmethod from_dict(obj)

Create an instance of DatasourceFlowsUpdateDataflowConfig from a dict

Return type:

Optional[Self]