airflow.providers.microsoft.azure.transfers.local_to_wasb

模組內容

類別

LocalFilesystemToWasbOperator

將檔案上傳到 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')[原始碼]
execute(context)[原始碼]

將檔案上傳到 Azure Blob 儲存體。

此條目是否有幫助?