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

此模块包含 AWS 到 AWS 传输操作符的基础类。

模块内容¶

类¶

AwsToAwsBaseOperator

AWS 到 AWS 传输操作符的基类。

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

基类: airflow.models.BaseOperator

AWS 到 AWS 传输操作符的基类。

参数

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')[源代码]¶

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

模块内容¶

类¶

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