airflow.providers.google.cloud.hooks.life_sciences

用于 Google Cloud Life Sciences 服务的 Hook。

模块内容

LifeSciencesHook

用于 Google Cloud Life Sciences API 的 Hook。

属性

TIME_TO_SLEEP_IN_SECONDS

airflow.providers.google.cloud.hooks.life_sciences.TIME_TO_SLEEP_IN_SECONDS = 5[源代码]
class airflow.providers.google.cloud.hooks.life_sciences.LifeSciencesHook(api_version='v2beta', gcp_conn_id='google_cloud_default', impersonation_chain=None, **kwargs)[源代码]

基类: airflow.providers.google.common.hooks.base_google.GoogleBaseHook

用于 Google Cloud Life Sciences API 的 Hook。

警告

此 hook 已弃用。请考虑改用 Google Cloud Batch Operators 的 hook。生命科学 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 的链式帐户列表,该帐户将在请求中被模拟。如果设置为字符串,则该帐户必须授予原始帐户“服务帐户令牌创建者”IAM 角色。如果设置为序列,则列表中的身份必须将“服务帐户令牌创建者”IAM 角色授予紧接其前的身份,列表中的第一个帐户将此角色授予原始帐户。

get_conn()[源代码]

检索与 Cloud Life Sciences 的连接。

返回

Google Cloud Life Sciences 服务对象。

返回类型

googleapiclient.discovery.build

run_pipeline(body, location, project_id)[源代码]

运行管道。

参数
  • body (dict) – 请求正文。

  • location (str) – 项目的位置。例如:“us-east1”。

  • project_id (str) – 可选,Google Cloud Project project_id,函数属于该项目。如果设置为 None 或缺失,则使用 Google Cloud 连接中的默认 project_id。

此条目是否有帮助?