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)[原始碼]

基底： 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 所需的鏈式帳戶清單，該帳戶將在請求中被模擬身分。如果設定為字串，則帳戶必須授予原始帳戶「服務帳戶權杖建立者」IAM 角色。如果設定為序列，則清單中的身分必須授予緊接在前的身分「服務帳戶權杖建立者」IAM 角色，清單中的第一個帳戶將此角色授予原始帳戶。

get_conn()[原始碼]

擷取與 GCE Batch 的連線。

返回

Google Batch 服務用戶端物件。

submit_batch_job(job_name, job, region, project_id=PROVIDE_PROJECT_ID)[原始碼]
delete_job(job_name, region, project_id=PROVIDE_PROJECT_ID)[原始碼]
list_jobs(region, project_id=PROVIDE_PROJECT_ID, filter=None, limit=None)[原始碼]
list_tasks(region, job_name, project_id=PROVIDE_PROJECT_ID, group_name='group0', filter=None, limit=None)[原始碼]
wait_for_job(job_name, polling_period_seconds=10, timeout=None)[原始碼]
get_job(job_name)[原始碼]
class airflow.providers.google.cloud.hooks.cloud_batch.CloudBatchAsyncHook(gcp_conn_id='google_cloud_default', impersonation_chain=None, **kwargs)[原始碼]

基底： 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 所需的鏈式帳戶清單，該帳戶將在請求中被模擬身分。如果設定為字串，則帳戶必須授予原始帳戶「服務帳戶權杖建立者」IAM 角色。如果設定為序列，則清單中的身分必須授予緊接在前的身分「服務帳戶權杖建立者」IAM 角色，清單中的第一個帳戶將此角色授予原始帳戶。

get_conn()[原始碼]

傳回 hook 的連線。

async get_batch_job(job_name)[原始碼]

此條目是否實用？