airflow.providers.google.cloud.hooks.life_sciences¶

Google Cloud Life Sciences 服务的 Hook。

属性¶

TIME_TO_SLEEP_IN_SECONDS

类¶

LifeSciencesHook

Google Cloud Life Sciences API 的 Hook。

模块内容¶

airflow.providers.google.cloud.hooks.life_sciences.TIME_TO_SLEEP_IN_SECONDS = 5[source]¶

class airflow.providers.google.cloud.hooks.life_sciences.LifeSciencesHook(api_version='v2beta', gcp_conn_id='google_cloud_default', impersonation_chain=None, **kwargs)[source]¶

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

Google Cloud Life Sciences API 的 Hook。

警告

此 Hook 已被弃用。请考虑改用 Google Cloud Batch Operators 的 Hook。Life Sciences API (beta) 将于 2025 年 7 月 8 日停止服务，推荐使用 Google Cloud Batch。

Hook 中使用 project_id 的所有方法都必须使用关键字参数调用，而不是位置参数。

参数:

api_version (str) – 使用的 API 版本（例如 v1 或 v1beta1）。
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 角色给直接位于其之前的身份，列表中第一个帐号将此角色授予发起帐号。

api_version = 'v2beta'[source]¶

get_conn()[source]¶

检索 Cloud Life Sciences 的连接。

返回:: Google Cloud Life Sciences 服务对象。
返回类型:: googleapiclient.discovery.build

run_pipeline(body, location, project_id)[source]¶

运行流水线。

参数:

body (dict) – 请求正文。
location (str) – 项目的位置。例如：“us-east1”。
project_id (str) – 可选，函数所属的 Google Cloud 项目 project_id。如果设置为 None 或缺失，则使用 Google Cloud 连接中的默认 project_id。