airflow.providers.google.cloud.hooks.functions

此模块包含 Google Cloud Functions Hook。

模块内容

类

CloudFunctionsHook

Google Cloud Functions API。

属性

TIME_TO_SLEEP_IN_SECONDS

airflow.providers.google.cloud.hooks.functions.TIME_TO_SLEEP_IN_SECONDS = 1[源代码]
class airflow.providers.google.cloud.hooks.functions.CloudFunctionsHook(api_version, gcp_conn_id='google_cloud_default', impersonation_chain=None, **kwargs)[源代码]

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

Google Cloud Functions API。

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

get_conn()[源代码]

检索到 Cloud Functions 的连接。

返回

Google Cloud Function 服务对象。

返回类型

googleapiclient.discovery.build

get_function(name)[源代码]

获取具有给定名称的 Cloud Function。

参数

name (str) – 函数的名称。

返回

表示该函数的 Cloud Functions 对象。

返回类型

dict

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

在 body 中指定的位置创建一个新函数。

参数

  • location (str) – 函数的位置。

  • body (dict) – Cloud Functions insert API 所需的 body。

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

update_function(name, body, update_mask)[源代码]

根据指定的更新掩码更新 Cloud Functions。

参数

  • name (str) – 函数的名称。

  • body (dict) – cloud function patch API 所需的 body。

  • update_mask (list[str]) – 更新掩码 - 应该修补的字段数组。

upload_function_zip(location, zip_path, project_id)[源代码]

上传带有源代码的 ZIP 文件。

参数

  • location (str) – 创建函数的位置。

  • zip_path (str) – 要上传的有效 .zip 文件的路径。

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

返回

generateUploadUrl 方法返回的上传 URL。

返回类型

str

delete_function(name)[源代码]

删除指定的 Cloud Function。

参数

name (str) – 函数的名称。

call_function(function_id, input_data, location, project_id=PROVIDE_PROJECT_ID)[源代码]

调用已部署的 Cloud Function。

这是同步完成的，应该仅用于测试目的，因为只允许非常有限的流量。

参数

  • function_id (str) – 要调用的函数的 ID

  • input_data (dict) – 要传递给函数的输入

  • location (str) – 函数所在的位置。

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

此条目是否有帮助？