airflow.providers.amazon.aws.hooks.dms

類

DmsTaskWaiterStatus

可用的 AWS DMS 任務等待器狀態。

DmsHook

與 AWS Database Migration Service (DMS) 互動。

模組內容

class airflow.providers.amazon.aws.hooks.dms.DmsTaskWaiterStatus[source]

Bases: str, enum.Enum

可用的 AWS DMS 任務等待器狀態。

DELETED = 'deleted'[source]
READY = 'ready'[source]
RUNNING = 'running'[source]
STOPPED = 'stopped'[source]
class airflow.providers.amazon.aws.hooks.dms.DmsHook(*args, **kwargs)[source]

Bases: airflow.providers.amazon.aws.hooks.base_aws.AwsBaseHook

與 AWS Database Migration Service (DMS) 互動。

提供圍繞 boto3.client("dms") 的精簡封裝。

可以指定附加引數（例如 aws_conn_id），這些引數將傳遞給底層的 AwsBaseHook。

另請參閱

describe_replication_tasks(**kwargs)[source]

描述複製任務。

另請參閱

返回:

標記和複製任務列表

返回型別:

tuple[str | None, list]

find_replication_tasks_by_arn(replication_task_arn, without_settings=False)[source]

按任務 ARN 查詢並描述複製任務。

另請參閱

引數:

  • replication_task_arn (str) – 複製任務 ARN

  • without_settings (bool | None) – 指示是否返回包含設定的任務資訊。

返回:

匹配 ARN 的複製任務列表

get_task_status(replication_task_arn)[source]

檢索任務狀態。

引數:

replication_task_arn (str) – 複製任務 ARN

返回:

當前任務狀態

返回型別:

str | None

create_replication_task(replication_task_id, source_endpoint_arn, target_endpoint_arn, replication_instance_arn, migration_type, table_mappings, **kwargs)[source]

建立 DMS 複製任務。

另請參閱

引數:

  • replication_task_id (str) – 複製任務 ID

  • source_endpoint_arn (str) – 源端點 ARN

  • target_endpoint_arn (str) – 目標端點 ARN

  • replication_instance_arn (str) – 複製例項 ARN

  • table_mappings (dict) – 表對映

  • migration_type (str) – 遷移型別 ('full-load'|'cdc'|'full-load-and-cdc')，預設為 full-load。

返回:

複製任務 ARN

返回型別:

str

start_replication_task(replication_task_arn, start_replication_task_type, **kwargs)[source]

啟動複製任務。

另請參閱

引數:

  • replication_task_arn (str) – 複製任務 ARN

  • start_replication_task_type (str) – 複製任務啟動型別（預設='start-replication'）（'start-replication'|'resume-processing'|'reload-target'）

stop_replication_task(replication_task_arn)[source]

停止複製任務。

另請參閱

引數:

replication_task_arn – 複製任務 ARN

delete_replication_task(replication_task_arn)[source]

啟動複製任務刪除並等待其被刪除。

另請參閱

引數:

replication_task_arn – 複製任務 ARN

wait_for_task_status(replication_task_arn, status)[source]

等待複製任務達到指定狀態；支援的狀態包括：deleted、ready、running、stopped。

引數:
describe_replication_configs(filters=None, **kwargs)[source]

返回無伺服器複製配置列表。

另請參閱

引數:

filters (list[dict] | None) – 過濾器物件列表

返回:

複製配置列表

返回型別:

list[dict]

create_replication_config(replication_config_id, source_endpoint_arn, target_endpoint_arn, compute_config, replication_type, table_mappings, additional_config_kwargs=None, **kwargs)[source]

建立一個 AWS DMS 無伺服器配置，可用於啟動 DMS 無伺服器複製。

另請參閱

引數:

  • replicationConfigId – 用於建立 ReplicationConfigArn 的唯一識別符號。

  • sourceEndpointArn – 源端點 ARN

  • targetEndpointArn – 目標端點 ARN

  • computeConfig – 用於預置 DMS 無伺服器複製的引數。

  • replicationType – DMS 無伺服器複製的型別

  • tableMappings – JSON 表對映

  • tags – 鍵值標籤對

  • resourceId – 您為給定資源設定的唯一值或名稱，可用於構造該資源的 Amazon Resource Name (ARN)。

  • supplementalSettings – 用於指定補充資料的 JSON 設定

  • replicationSettings – DMS 無伺服器複製的 JSON 設定

返回:

ReplicationConfigArn

describe_replications(filters=None, **kwargs)[source]

返回無伺服器複製列表。

另請參閱

引數:

filters (list[dict[str, Any]] | None) – 過濾器物件列表

返回:

複製列表

返回型別:

list[dict]

delete_replication_config(replication_config_arn, delay=60, max_attempts=120)[source]

刪除 AWS DMS 無伺服器配置。

另請參閱

引數:

replication_config_arn (str) – ReplicationConfigArn

start_replication(replication_config_arn, start_replication_type, cdc_start_time=None, cdc_start_pos=None, cdc_stop_pos=None)[source]
stop_replication(replication_config_arn)[source]
get_provision_status(replication_config_arn)[source]

獲取無伺服器複製的預置狀態。

此條目是否有幫助？