airflow.providers.google.cloud.hooks.cloud_run¶

类¶

`CloudRunHook`	Google Cloud Run 服务的 Hook。
`CloudRunAsyncHook`	Google Cloud Run 服务的异步 Hook。
`CloudRunServiceHook`	Google Cloud Run 服务的 Hook。
`CloudRunServiceAsyncHook`	Google Cloud Run 服务的异步 Hook。

模块内容¶

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

Bases: airflow.providers.google.common.hooks.base_google.GoogleBaseHook

Google Cloud Run 服务的 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]¶

获取 Cloud Run 连接。

返回值：: Cloud Run Jobs 客户端对象。

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

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

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

execute_job(job_name, region, project_id=PROVIDE_PROJECT_ID, overrides=None)[source]¶

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

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

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

Bases: airflow.providers.google.common.hooks.base_google.GoogleBaseHook

Google Cloud Run 服务的异步 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_operation(operation_name)[source]¶

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

Bases: airflow.providers.google.common.hooks.base_google.GoogleBaseHook

Google Cloud Run 服务的 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 的连接。

get_service(service_name, region, project_id=PROVIDE_PROJECT_ID)[source]¶

create_service(service_name, service, region, project_id=PROVIDE_PROJECT_ID)[source]¶

delete_service(service_name, region, project_id=PROVIDE_PROJECT_ID)[source]¶

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

Bases: airflow.providers.google.common.hooks.base_google.GoogleBaseHook

Google Cloud Run 服务的异步 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 create_service(service_name, service, region, project_id=PROVIDE_PROJECT_ID)[source]¶

async delete_service(service_name, region, project_id=PROVIDE_PROJECT_ID)[source]¶