airflow.providers.google.cloud.transfers.azure_blob_to_gcs¶

类¶

AzureBlobStorageToGCSOperator

操作符将数据从 Azure Blob Storage 传输到 Google Cloud Storage 中的指定存储桶。

模块内容¶

class airflow.providers.google.cloud.transfers.azure_blob_to_gcs.AzureBlobStorageToGCSOperator(*, wasb_conn_id='wasb_default', gcp_conn_id='google_cloud_default', blob_name, container_name, bucket_name, object_name, filename, gzip, impersonation_chain=None, **kwargs)[source]¶

基类: airflow.models.BaseOperator

操作符将数据从 Azure Blob Storage 传输到 Google Cloud Storage 中的指定存储桶。

另请参阅

有关如何使用此操作符的更多信息，请查看指南: 从 Azure Blob Storage 传输数据到 Google Cloud Storage

参数:

wasb_conn_id – 对 wasb 连接的引用。
gcp_conn_id (str) – 获取连接信息时使用的连接 ID。
blob_name (str) – Blob 的名称
container_name (str) – 容器的名称
bucket_name (str) – 要上传到的存储桶
object_name (str) – 上传文件时要设置的对象名称
filename (str) – 要上传文件的本地文件路径
gzip (bool) – 上传时压缩本地文件或文件数据的选项
impersonation_chain (str | collections.abc.Sequence[str] | None) – 可选的服务账号，用于使用短期凭据进行模拟，或者用于获取列表中最后一个账号（将在请求中模拟）的 access_token 所需的账号链。如果设置为字符串，则原始账号必须向该服务账号授予 Service Account Token Creator IAM 角色。如果设置为序列，列表中的身份必须向其直接前一个身份授予 Service Account Token Creator IAM 角色，列表中第一个账号将此角色授予原始账号。

wasb_conn_id = 'wasb_default'[source]¶

gcp_conn_id = 'google_cloud_default'[source]¶

blob_name[source]¶

container_name[source]¶

bucket_name[source]¶

object_name[source]¶

filename[source]¶

gzip[source]¶

impersonation_chain = None[source]¶

template_fields: collections.abc.Sequence[str] = ('blob_name', 'container_name', 'bucket_name', 'object_name', 'filename')[source]¶

execute(context)[source]¶

创建操作符时派生此方法。

Context 是与渲染 jinja 模板时使用的字典相同的字典。

有关更多上下文信息，请参阅 get_template_context。

get_openlineage_facets_on_start()[source]¶