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)[源代码]

基类: 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 所需的链式帐户列表，该帐户将在请求中模拟。如果设置为字符串，则该帐户必须授予原始帐户“服务帐户令牌创建者”IAM 角色。如果设置为序列，则列表中的身份必须将“服务帐户令牌创建者”IAM 角色授予紧随其后的身份，列表中的第一个帐户将此角色授予原始帐户。

get_conn()[源代码]

检索与 Cloud Run 的连接。

返回

Cloud Run Jobs 客户端对象。

delete_job(job_name, region, project_id=PROVIDE_PROJECT_ID)[源代码]
create_job(job_name, job, region, project_id=PROVIDE_PROJECT_ID)[源代码]
update_job(job_name, job, region, project_id=PROVIDE_PROJECT_ID)[源代码]
execute_job(job_name, region, project_id=PROVIDE_PROJECT_ID, overrides=None)[源代码]
get_job(job_name, region, project_id=PROVIDE_PROJECT_ID)[源代码]
list_jobs(region, project_id=PROVIDE_PROJECT_ID, show_deleted=False, limit=None)[源代码]
class airflow.providers.google.cloud.hooks.cloud_run.CloudRunAsyncHook(gcp_conn_id='google_cloud_default', impersonation_chain=None, **kwargs)[源代码]

基类: 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 所需的链式帐户列表，该帐户将在请求中模拟。如果设置为字符串，则该帐户必须授予原始帐户“服务帐户令牌创建者”IAM 角色。如果设置为序列，则列表中的身份必须将“服务帐户令牌创建者”IAM 角色授予紧随其后的身份，列表中的第一个帐户将此角色授予原始帐户。

get_conn()[源代码]

返回 hook 的连接。

async get_operation(operation_name)[源代码]
class airflow.providers.google.cloud.hooks.cloud_run.CloudRunServiceHook(gcp_conn_id='google_cloud_default', impersonation_chain=None, **kwargs)[源代码]

基类: 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 所需的链式帐户列表，该帐户将在请求中模拟。如果设置为字符串，则该帐户必须授予原始帐户“服务帐户令牌创建者”IAM 角色。如果设置为序列，则列表中的身份必须将“服务帐户令牌创建者”IAM 角色授予紧随其后的身份，列表中的第一个帐户将此角色授予原始帐户。

get_conn()[源代码]

返回 hook 的连接。

get_service(service_name, region, project_id=PROVIDE_PROJECT_ID)[源代码]
create_service(service_name, service, region, project_id=PROVIDE_PROJECT_ID)[源代码]
delete_service(service_name, region, project_id=PROVIDE_PROJECT_ID)[源代码]
class airflow.providers.google.cloud.hooks.cloud_run.CloudRunServiceAsyncHook(gcp_conn_id='google_cloud_default', impersonation_chain=None, **kwargs)[源代码]

基类: 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 所需的链式帐户列表，该帐户将在请求中模拟。如果设置为字符串，则该帐户必须授予原始帐户“服务帐户令牌创建者”IAM 角色。如果设置为序列，则列表中的身份必须将“服务帐户令牌创建者”IAM 角色授予紧随其后的身份，列表中的第一个帐户将此角色授予原始帐户。

get_conn()[源代码]

返回 hook 的连接。

async create_service(service_name, service, region, project_id=PROVIDE_PROJECT_ID)[源代码]
async delete_service(service_name, region, project_id=PROVIDE_PROJECT_ID)[源代码]

此条目是否有帮助？