airflow.providers.amazon.aws.operators.dms_create_task

Module Contents

class airflow.providers.amazon.aws.operators.dms_create_task.DmsCreateTaskOperator(*, replication_task_id: str, source_endpoint_arn: str, target_endpoint_arn: str, replication_instance_arn: str, table_mappings: dict, migration_type: Optional[str] = 'full-load', create_task_kwargs: Optional[dict] = None, aws_conn_id: str = 'aws_default', **kwargs)[source]

Bases: airflow.models.BaseOperator

Creates AWS DMS replication task.

See also

For more information on how to use this operator, take a look at the guide: Create replication task, wait for it completion and delete it.

Parameters

  • replication_task_id (str) -- Replication task id

  • source_endpoint_arn (str) -- Source endpoint ARN

  • target_endpoint_arn (str) -- Target endpoint ARN

  • replication_instance_arn (str) -- Replication instance ARN

  • table_mappings (dict) -- Table mappings

  • migration_type (str) -- Migration type ('full-load'|'cdc'|'full-load-and-cdc'), full-load by default.

  • create_task_kwargs (Optional[dict]) -- Extra arguments for DMS replication task creation.

  • aws_conn_id (Optional[str]) -- The Airflow connection used for AWS credentials. If this is None or empty then the default boto3 behaviour is used. If running Airflow in a distributed manner and aws_conn_id is None or empty, then default boto3 configuration would be used (and must be maintained on each worker node).

template_fields = ['replication_task_id', 'source_endpoint_arn', 'target_endpoint_arn', 'replication_instance_arn', 'table_mappings', 'migration_type', 'create_task_kwargs'][source]
template_ext = [][source]
template_fields_renderers[source]
execute(self, context)[source]

Creates AWS DMS replication task from Airflow

Returns

replication task arn

Was this entry helpful?