DmsCreateTaskOperator
AmazonCreates AWS DMS replication task.
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.
Parameters
replication_task_idRequiredReplication task id
source_endpoint_arnRequiredSource endpoint ARN
target_endpoint_arnRequiredTarget endpoint ARN
replication_instance_arnRequiredReplication instance ARN
table_mappingsRequiredTable mappings
migration_typeMigration type (‘full-load’|’cdc’|’full-load-and-cdc’), full-load by default.
create_task_kwargsExtra arguments for DMS replication task creation.
aws_conn_idThe 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).
Documentation
Creates AWS DMS replication task.
See also
For more information on how to use this operator, take a look at the guide: Create a replication task