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。

此條目是否有用?