airflow.providers.microsoft.azure.transfers.local_to_wasb¶

类¶

LocalFilesystemToWasbOperator

将文件上传到 Azure Blob Storage。

模块内容¶

class airflow.providers.microsoft.azure.transfers.local_to_wasb.LocalFilesystemToWasbOperator(*, file_path, container_name, blob_name, wasb_conn_id='wasb_default', create_container=False, load_options=None, **kwargs)[source]¶

基类：airflow.models.BaseOperator

将文件上传到 Azure Blob Storage。

参数：

file_path (str) – 要加载的文件路径。(模板化)
container_name (str) – 容器名称。(模板化)
blob_name (str) – Blob 名称。(模板化)
wasb_conn_id (str) – Wasb 连接的引用。
create_container (bool) – 在上传 blob 之前尝试创建目标容器。如果目标容器可能尚未存在，这很有用。默认为 False。
load_options (dict | None) – WasbHook.load_file() 可选接受的关键字参数。

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

file_path[source]¶

container_name[source]¶

blob_name[source]¶

wasb_conn_id = 'wasb_default'[source]¶

create_container = False[source]¶

load_options = None[source]¶

execute(context)[source]¶

将文件上传到 Azure Blob Storage。