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]¶