airflow.providers.google.suite.transfers.gcs_to_gdrive

此模組包含一個 Google Cloud Storage 到 Google Drive 的傳輸運算子。

屬性

WILDCARD

GCSToGoogleDriveOperator

將物件從 Google Cloud Storage 服務複製到 Google Drive 服務,如果需要則進行重新命名。

模組內容

airflow.providers.google.suite.transfers.gcs_to_gdrive.WILDCARD = '*'[原始碼]
class airflow.providers.google.suite.transfers.gcs_to_gdrive.GCSToGoogleDriveOperator(*, source_bucket, source_object, destination_object=None, destination_folder_id='root', move_object=False, gcp_conn_id='google_cloud_default', impersonation_chain=None, **kwargs)[原始碼]

基類: airflow.models.BaseOperator

將物件從 Google Cloud Storage 服務複製到 Google Drive 服務,如果需要則進行重新命名。

使用此運算子需要以下 OAuth 2.0 範圍

https://www.googleapis.com/auth/drive

另請參閱

有關如何使用此運算子的更多資訊,請參閱指南: 運算子

引數:
  • source_bucket (str) – 物件所在的源 Google Cloud Storage 儲存桶。(模板化)

  • source_object (str) – 要複製到 Google Cloud Storage 儲存桶中的物件的源名稱。(模板化) 您只能在儲存桶內的物件(檔名)中使用一個萬用字元。萬用字元可以出現在物件名稱內部或物件名稱末尾。不支援在儲存桶名稱後附加萬用字元。

  • destination_object (str | None) – 目標 Google Drive 服務中物件的目的地名稱。(模板化) 如果 source_object 引數中提供了萬用字元,則此引數是最終目標物件路徑將新增的字首。請注意,萬用字元之前的源路徑部分將被移除;如果需要保留,應將其附加到 destination_object。例如,對於字首 foo/* 和 destination_object blah/,檔案 foo/baz 將複製到 blah/baz;要保留字首,請將 destination_object 寫為例如 blah/foo,此時複製的檔案將命名為 blah/foo/baz

  • destination_folder_id (str) – 目標物件將放置的資料夾 ID。它是在 destination_object 中指定的任何內容之前的附加字首。例如,如果資料夾 ID xXyYzZ 被稱為 foo,並且目的地是 bar/baz,則檔案最終將位於 foo/bar/baz。這可用於指定一個已對其他使用者可見的現有資料夾。提供的憑據必須具有訪問此資料夾的許可權。

  • move_object (bool) – 當 move_object 為 True 時,物件將被移動而不是複製到新位置。這相當於 mv 命令而非 cp 命令。

  • gcp_conn_id (str) – (可選) 用於連線 Google Cloud 的連線 ID。

  • impersonation_chain (str | collections.abc.Sequence[str] | None) – (可選) 使用短期憑據模擬的服務帳號,或是獲取列表中最後一個帳號 access_token 所需的帳號鏈列表,該帳號將在請求中被模擬。如果設定為字串,該帳號必須授予發起帳號 Service Account Token Creator IAM 角色。如果設定為序列,列表中的身份必須授予緊接其前的身份 Service Account Token Creator IAM 角色,列表中的第一個帳號則將此角色授予發起帳號。(模板化)

template_fields: collections.abc.Sequence[str] = ('source_bucket', 'source_object', 'destination_object', 'impersonation_chain')[原始碼]
ui_color = '#f0eee4'[原始碼]
source_bucket[原始碼]
source_object[原始碼]
destination_object = None[原始碼]
destination_folder_id = 'root'[原始碼]
move_object = False[原始碼]
gcp_conn_id = 'google_cloud_default'[原始碼]
impersonation_chain = None[原始碼]
gcs_hook: airflow.providers.google.cloud.hooks.gcs.GCSHook | None = None[原始碼]
gdrive_hook: airflow.providers.google.suite.hooks.drive.GoogleDriveHook | None = None[原始碼]
execute(context)[原始碼]

建立運算子時派生此方法。

上下文與渲染 jinja 模板時使用的字典相同。

有關更多上下文資訊,請參閱 get_template_context。

本條目是否有幫助?