airflow.providers.google.cloud.transfers.local_to_gcs¶
此模組包含用於將本機檔案上傳到 GCS 的運算子。
模組內容¶
類別¶
將檔案或檔案清單上傳到 Google Cloud Storage；可選擇壓縮檔案以上傳；可選擇將資料分成多個區塊上傳。 |
- class airflow.providers.google.cloud.transfers.local_to_gcs.LocalFilesystemToGCSOperator(*, src, dst, bucket, gcp_conn_id='google_cloud_default', mime_type='application/octet-stream', gzip=False, chunk_size=None, impersonation_chain=None, **kwargs)[原始碼]¶
基底類別:
airflow.models.BaseOperator將檔案或檔案清單上傳到 Google Cloud Storage；可選擇壓縮檔案以上傳；可選擇將資料分成多個區塊上傳。
參見
如需更多關於如何使用此運算子的資訊，請查看指南： LocalFilesystemToGCSOperator
- 參數
src (str | list[str]) – 本機檔案的路徑，或本機檔案的清單。路徑可以是絕對路徑（例如 /path/to/file.ext）或相對路徑（例如 ../../foo//.csv）。（已套用 Jinja 模板）
dst (str) – GCS 上指定儲存貯體內的目標路徑（例如 /path/to/file.ext）。如果正在上傳多個檔案，請指定帶有尾部反斜線的物件前綴（例如 /path/to/directory/）（已套用 Jinja 模板）
bucket (str) – 要上傳到的儲存貯體。（已套用 Jinja 模板）
gcp_conn_id (str) – （選用）用於連線至 Google Cloud 的連線 ID。
mime_type (str) – MIME 類型字串
gzip (bool) – 允許將檔案壓縮並以 gzip 格式上傳
chunk_size (int | None) – Blob 區塊大小（以位元組為單位）。這必須是 262144 位元組（256 KiB）的倍數
impersonation_chain (str | collections.abc.Sequence[str] | None) – 選用的服務帳戶，用於使用短期憑證模擬身分，或取得清單中最後一個帳戶的 access_token 所需的帳戶鏈結清單，該帳戶將在請求中被模擬身分。如果設定為字串，則該帳戶必須授予原始帳戶「服務帳戶權杖建立者」IAM 角色。如果設定為序列，則清單中的身分必須將「服務帳戶權杖建立者」IAM 角色授予緊鄰的前一個身分，清單中的第一個帳戶將此角色授予原始帳戶（已套用 Jinja 模板）。
- template_fields: collections.abc.Sequence[str] = ('src', 'dst', 'bucket', 'impersonation_chain')[原始碼]¶