Creates AWS DMS replication task.

View on GitHub

Last Updated: Aug. 30, 2021

Access Instructions

Install the Amazon provider package into your Airflow environment.

Import the module into your DAG file and instantiate it with your desired params.


replication_task_idRequiredstrReplication task id
source_endpoint_arnRequiredstrSource endpoint ARN
target_endpoint_arnRequiredstrTarget endpoint ARN
replication_instance_arnRequiredstrReplication instance ARN
table_mappingsRequireddictTable mappings
migration_typestrMigration type (‘full-load’|’cdc’|’full-load-and-cdc’), full-load by default.
create_task_kwargsOptional[dict]Extra arguments for DMS replication task creation.
aws_conn_idOptional[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).


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.

Was this page helpful?