airflow.providers.microsoft.azure.transfers.local_to_wasb¶
模块内容¶
类¶
将文件上传到 Azure Blob 存储。 |
- 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)[源代码]¶
基类：
airflow.models.BaseOperator将文件上传到 Azure Blob 存储。
- 参数
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')[源代码]¶