airflow.providers.amazon.aws.transfers.base¶

此模組包含基本的 AWS 到 AWS 的傳輸 operator。

類¶

AwsToAwsBaseOperator

AWS 到 AWS 傳輸 operator 的基類。

模組內容¶

class airflow.providers.amazon.aws.transfers.base.AwsToAwsBaseOperator(*, source_aws_conn_id=AwsBaseHook.default_conn_name, dest_aws_conn_id=NOTSET, **kwargs)[source]¶

基類: airflow.models.BaseOperator

AWS 到 AWS 傳輸 operator 的基類。

引數:

source_aws_conn_id (str | None) – 用於訪問 DynamoDB 的 AWS 憑據的 Airflow 連線。如果此引數為 None 或為空，則使用預設的 boto3 行為。如果在分散式環境中執行 Airflow 且 source_aws_conn_id 為 None 或為空，則將使用預設的 boto3 配置（且必須在每個 worker 節點上維護）。
dest_aws_conn_id (str | None | airflow.utils.types.ArgNotSet) – 用於訪問 S3 的 AWS 憑據的 Airflow 連線。如果未設定此引數，則使用 source_aws_conn_id 連線。

template_fields: collections.abc.Sequence[str] = ('source_aws_conn_id', 'dest_aws_conn_id')[source]¶

source_aws_conn_id = 'aws_default'[source]¶

dest_aws_conn_id[source]¶