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]¶