airflow.providers.google.cloud.operators.cloud_batch¶
模組內容¶
類別¶
提交任務並等待其完成。 |
|
刪除任務並等待操作完成。 |
|
列出 Cloud Batch 任務。 |
|
列出指定任務的 Cloud Batch 工作。 |
- class airflow.providers.google.cloud.operators.cloud_batch.CloudBatchSubmitJobOperator(project_id, region, job_name, job, polling_period_seconds=10, timeout_seconds=None, gcp_conn_id='google_cloud_default', impersonation_chain=None, deferrable=conf.getboolean('operators', 'default_deferrable', fallback=False), **kwargs)[原始碼]¶
繼承自：
airflow.providers.google.cloud.operators.cloud_base.GoogleCloudBaseOperator提交任務並等待其完成。
- 參數
project_id (str) – 必填。服務所屬的 Google Cloud 專案 ID。
region (str) – 必填。服務所屬的 Google Cloud 區域 ID。
job_name (str) – 必填。要建立的任務名稱。
job (dict | google.cloud.batch_v1.Job) – 必填。包含要提交任務之組態的任務描述符。
polling_period_seconds (float) – 選填：控制延遲執行結果的輪詢速率。預設情況下，觸發器將每 10 秒輪詢一次。
timeout – 此請求的逾時時間。
gcp_conn_id (str) – 用於連線至 Google Cloud 的連線 ID。
impersonation_chain (str | collections.abc.Sequence[str] | None) – 選填服務帳戶以使用短期憑證模擬，或取得清單中最後一個帳戶的 access_token 所需的帳戶鏈結清單，該帳戶將在請求中被模擬。如果設定為字串，則該帳戶必須授予原始帳戶「服務帳戶權杖建立者」IAM 角色。如果設定為序列，則清單中的身分必須將「服務帳戶權杖建立者」IAM 角色授予緊鄰的前一個身分，清單中的第一個帳戶將此角色授予原始帳戶（可使用範本）。
deferrable (bool) – 在可延遲模式下執行運算子
- class airflow.providers.google.cloud.operators.cloud_batch.CloudBatchDeleteJobOperator(project_id, region, job_name, timeout=None, gcp_conn_id='google_cloud_default', impersonation_chain=None, **kwargs)[原始碼]¶
繼承自：
airflow.providers.google.cloud.operators.cloud_base.GoogleCloudBaseOperator刪除任務並等待操作完成。
- 參數
project_id (str) – 必填。服務所屬的 Google Cloud 專案 ID。
region (str) – 必填。服務所屬的 Google Cloud 區域 ID。
job_name (str) – 必填。要刪除的任務名稱。
timeout (float | None) – 此請求的逾時時間。
gcp_conn_id (str) – 用於連線至 Google Cloud 的連線 ID。
impersonation_chain (str | collections.abc.Sequence[str] | None) – 選填服務帳戶以使用短期憑證模擬，或取得清單中最後一個帳戶的 access_token 所需的帳戶鏈結清單，該帳戶將在請求中被模擬。如果設定為字串，則該帳戶必須授予原始帳戶「服務帳戶權杖建立者」IAM 角色。如果設定為序列，則清單中的身分必須將「服務帳戶權杖建立者」IAM 角色授予緊鄰的前一個身分，清單中的第一個帳戶將此角色授予原始帳戶（可使用範本）。
- class airflow.providers.google.cloud.operators.cloud_batch.CloudBatchListJobsOperator(project_id, region, gcp_conn_id='google_cloud_default', filter=None, limit=None, impersonation_chain=None, **kwargs)[原始碼]¶
繼承自：
airflow.providers.google.cloud.operators.cloud_base.GoogleCloudBaseOperator列出 Cloud Batch 任務。
- 參數
project_id (str) – 必填。服務所屬的 Google Cloud 專案 ID。
region (str) – 必填。服務所屬的 Google Cloud 區域 ID。
gcp_conn_id (str) – 用於連線至 Google Cloud 的連線 ID。
filter (str | None) – 篩選器，用於列出任務。如果留空，則會列出所有任務。
limit (int | None) – 要列出的任務數量。如果留空，則會傳回所有符合篩選器的任務。
impersonation_chain (str | collections.abc.Sequence[str] | None) – 選填服務帳戶以使用短期憑證模擬，或取得清單中最後一個帳戶的 access_token 所需的帳戶鏈結清單，該帳戶將在請求中被模擬。如果設定為字串，則該帳戶必須授予原始帳戶「服務帳戶權杖建立者」IAM 角色。如果設定為序列，則清單中的身分必須將「服務帳戶權杖建立者」IAM 角色授予緊鄰的前一個身分，清單中的第一個帳戶將此角色授予原始帳戶（可使用範本）。
- class airflow.providers.google.cloud.operators.cloud_batch.CloudBatchListTasksOperator(project_id, region, job_name, gcp_conn_id='google_cloud_default', impersonation_chain=None, group_name='group0', filter=None, limit=None, **kwargs)[原始碼]¶
繼承自：
airflow.providers.google.cloud.operators.cloud_base.GoogleCloudBaseOperator列出指定任務的 Cloud Batch 工作。
- 參數
project_id (str) – 必填。服務所屬的 Google Cloud 專案 ID。
region (str) – 必填。服務所屬的 Google Cloud 區域 ID。
job_name (str) – 必填。要列出任務的任務名稱。
gcp_conn_id (str) – 用於連線至 Google Cloud 的連線 ID。
filter (str | None) – 篩選器，用於列出任務。如果留空，則會列出所有任務。
group_name (str) – 擁有任務的群組名稱。預設為 group0。
limit (int | None) – 要列出的任務數量。如果留空，則會傳回所有符合篩選器的任務。
impersonation_chain (str | collections.abc.Sequence[str] | None) – 選填服務帳戶以使用短期憑證模擬，或取得清單中最後一個帳戶的 access_token 所需的帳戶鏈結清單，該帳戶將在請求中被模擬。如果設定為字串，則該帳戶必須授予原始帳戶「服務帳戶權杖建立者」IAM 角色。如果設定為序列，則清單中的身分必須將「服務帳戶權杖建立者」IAM 角色授予緊鄰的前一個身分，清單中的第一個帳戶將此角色授予原始帳戶（可使用範本）。