airflow.providers.google.cloud.hooks.cloud_batch¶

類¶

`CloudBatchHook`	Google Cloud Batch 服務的 Hook。
`CloudBatchAsyncHook`	Google Cloud Batch 服務的非同步 Hook。

模組內容¶

class airflow.providers.google.cloud.hooks.cloud_batch.CloudBatchHook(gcp_conn_id='google_cloud_default', impersonation_chain=None, **kwargs)[source]¶

基類: airflow.providers.google.common.hooks.base_google.GoogleBaseHook

Google Cloud Batch 服務的 Hook。

引數:

gcp_conn_id (str) – 獲取連線資訊時使用的連線 ID。
impersonation_chain (str | collections.abc.Sequence[str] | None) – 可選的服務賬號，用於使用短期憑據進行模擬，或者獲取列表中最後一個賬號的 access_token 所需的鏈式賬號列表，該賬號將在請求中被模擬。如果設定為字串，該賬號必須授予發起賬號 Service Account Token Creator IAM 角色。如果設定為序列，列表中的身份必須授予緊接在其前的身份 Service Account Token Creator IAM 角色，列表中第一個賬號將此角色授予發起賬號。

get_conn()[source]¶

檢索到 GCE Batch 的連線。

返回:: Google Batch Service 客戶端物件。

submit_batch_job(job_name, job, region, project_id=PROVIDE_PROJECT_ID)[source]¶

delete_job(job_name, region, project_id=PROVIDE_PROJECT_ID)[source]¶

list_jobs(region, project_id=PROVIDE_PROJECT_ID, filter=None, limit=None)[source]¶

list_tasks(region, job_name, project_id=PROVIDE_PROJECT_ID, group_name='group0', filter=None, limit=None)[source]¶

wait_for_job(job_name, polling_period_seconds=10, timeout=None)[source]¶

get_job(job_name)[source]¶

class airflow.providers.google.cloud.hooks.cloud_batch.CloudBatchAsyncHook(gcp_conn_id='google_cloud_default', impersonation_chain=None, **kwargs)[source]¶

基類: airflow.providers.google.common.hooks.base_google.GoogleBaseHook

Google Cloud Batch 服務的非同步 Hook。

引數:

gcp_conn_id (str) – 獲取連線資訊時使用的連線 ID。
impersonation_chain (str | collections.abc.Sequence[str] | None) – 可選的服務賬號，用於使用短期憑據進行模擬，或者獲取列表中最後一個賬號的 access_token 所需的鏈式賬號列表，該賬號將在請求中被模擬。如果設定為字串，該賬號必須授予發起賬號 Service Account Token Creator IAM 角色。如果設定為序列，列表中的身份必須授予緊接在其前的身份 Service Account Token Creator IAM 角色，列表中第一個賬號將此角色授予發起賬號。

get_conn()[source]¶: 返回 Hook 的連線。

async get_batch_job(job_name)[source]¶