airflow.providers.amazon.aws.hooks.dms
¶
Module Contents¶
Classes¶
Available AWS DMS Task Waiter statuses. |
|
Interact with AWS Database Migration Service (DMS). |
- class airflow.providers.amazon.aws.hooks.dms.DmsTaskWaiterStatus[source]¶
-
Available AWS DMS Task Waiter statuses.
- class airflow.providers.amazon.aws.hooks.dms.DmsHook(*args, **kwargs)[source]¶
Bases:
airflow.providers.amazon.aws.hooks.base_aws.AwsBaseHook
Interact with AWS Database Migration Service (DMS).
Provide thin wrapper around
boto3.client("dms")
.Additional arguments (such as
aws_conn_id
) may be specified and are passed down to the underlying AwsBaseHook.- find_replication_tasks_by_arn(replication_task_arn, without_settings=False)[source]¶
Find and describe replication tasks by task ARN.
- create_replication_task(replication_task_id, source_endpoint_arn, target_endpoint_arn, replication_instance_arn, migration_type, table_mappings, **kwargs)[source]¶
Create DMS replication task.
- 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.
- Returns
Replication task ARN
- Return type
- start_replication_task(replication_task_arn, start_replication_task_type, **kwargs)[source]¶
Start replication task.
- stop_replication_task(replication_task_arn)[source]¶
Stop replication task.
- Parameters
replication_task_arn – Replication task ARN
- delete_replication_task(replication_task_arn)[source]¶
Start replication task deletion and waits for it to be deleted.
- Parameters
replication_task_arn – Replication task ARN
- wait_for_task_status(replication_task_arn, status)[source]¶
Wait for replication task to reach status; supported statuses: deleted, ready, running, stopped.
- Parameters
status (DmsTaskWaiterStatus) – Status to wait for
replication_task_arn (str) – Replication task ARN