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。