airflow.providers.google.suite.transfers.gcs_to_gdrive¶
此模組包含一個 Google Cloud Storage 到 Google Drive 的傳輸運算子。
屬性¶
類¶
將物件從 Google Cloud Storage 服務複製到 Google Drive 服務,如果需要則進行重新命名。 |
模組內容¶
- 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_objectblah/,檔案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')[原始碼]¶
- gcs_hook: airflow.providers.google.cloud.hooks.gcs.GCSHook | None = None[原始碼]¶
- gdrive_hook: airflow.providers.google.suite.hooks.drive.GoogleDriveHook | None = None[原始碼]¶