airflow.providers.google.cloud.hooks.stackdriver

此模块包含 Google Cloud Stackdriver 操作符。

模块内容

类

StackdriverHook

用于连接 Google Cloud Stackdriver 的 Stackdriver Hook。
class airflow.providers.google.cloud.hooks.stackdriver.StackdriverHook(gcp_conn_id='google_cloud_default', impersonation_chain=None, **kwargs)[源代码]

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

用于连接 Google Cloud Stackdriver 的 Stackdriver Hook。

list_alert_policies(project_id=PROVIDE_PROJECT_ID, format_=None, filter_=None, order_by=None, page_size=None, retry=DEFAULT, timeout=None, metadata=())[源代码]

获取由作为过滤器参数传递的过滤器标识的所有警报策略。

所需的返回类型可以通过 format 参数指定，支持的格式为 “dict”、“json” 和 None，它们分别返回 python 字典、字符串化的 JSON 和 protobuf。

参数

  • format – (可选) 结果的期望输出格式。支持的格式为 “dict”、“json” 和 None，它们分别返回 python 字典、字符串化的 JSON 和 protobuf。

  • filter – 如果提供，则此字段指定警报策略要包含在响应中必须满足的条件。有关更多详细信息，请参阅 https://cloud.google.com/monitoring/api/v3/sorting-and-filtering。

  • order_by (str | None) – 用于对结果进行排序的逗号分隔的字段列表。支持与 filter 字段相同的一组字段引用。条目可以添加减号前缀，以按降序对字段进行排序。有关更多详细信息，请参阅 https://cloud.google.com/monitoring/api/v3/sorting-and-filtering。

  • page_size (int | None) – 底层 API 响应中包含的最大资源数。如果每个资源执行页面流式传输，则此参数不会影响返回值。如果每个页面执行页面流式传输，则此参数确定页面中的最大资源数。

  • retry (google.api_core.retry.Retry | google.api_core.gapic_v1.method._MethodDefault) – 用于重试请求的重试对象。如果指定 None，则将使用默认配置重试请求。

  • timeout (float | None) – 等待请求完成的时间量（以秒为单位）。请注意，如果指定了 retry，则超时适用于每次单独的尝试。

  • metadata (collections.abc.Sequence[tuple[str, str]]) – 提供给方法的其他元数据。

  • project_id (str) – 要从中获取警报的项目。

enable_alert_policies(project_id=PROVIDE_PROJECT_ID, filter_=None, retry=DEFAULT, timeout=None, metadata=())[源代码]

启用由过滤器参数标识的一个或多个已禁用的警报策略。

如果策略已启用，则无效。

参数

  • project_id (str) – 需要启用警报的项目。

  • filter – 如果提供，则此字段指定要启用的警报策略必须满足的条件。有关更多详细信息，请参阅 https://cloud.google.com/monitoring/api/v3/sorting-and-filtering。

  • retry (google.api_core.retry.Retry | google.api_core.gapic_v1.method._MethodDefault) – 用于重试请求的重试对象。如果指定 None，则将使用默认配置重试请求。

  • timeout (float | None) – 等待请求完成的时间量（以秒为单位）。请注意，如果指定了 retry，则超时适用于每次单独的尝试。

  • metadata (collections.abc.Sequence[tuple[str, str]]) – 提供给方法的其他元数据。

disable_alert_policies(project_id=PROVIDE_PROJECT_ID, filter_=None, retry=DEFAULT, timeout=None, metadata=())[源代码]

禁用由过滤器参数标识的一个或多个已启用的警报策略。

如果策略已禁用，则无效。

参数

  • project_id (str) – 需要禁用警报的项目。

  • filter – 如果提供，则此字段指定要禁用的警报策略必须满足的条件。有关更多详细信息，请参阅 https://cloud.google.com/monitoring/api/v3/sorting-and-filtering。

  • retry (google.api_core.retry.Retry | google.api_core.gapic_v1.method._MethodDefault) – 用于重试请求的重试对象。如果指定 None，则将使用默认配置重试请求。

  • timeout (float | None) – 等待请求完成的时间量（以秒为单位）。请注意，如果指定了 retry，则超时适用于每次单独的尝试。

  • metadata (collections.abc.Sequence[tuple[str, str]]) – 提供给方法的其他元数据。

upsert_alert(alerts, project_id=PROVIDE_PROJECT_ID, retry=DEFAULT, timeout=None, metadata=())[source]

创建新的警报或更新 alerts 参数中 name 字段标识的现有策略。

参数
delete_alert_policy(name, retry=DEFAULT, timeout=None, metadata=())[source]

删除警报策略。

参数

  • name ( str ) – 要删除的警报策略。格式为： projects/[PROJECT_ID]/alertPolicies/[ALERT_POLICY_ID]。

  • retry (google.api_core.retry.Retry | google.api_core.gapic_v1.method._MethodDefault) – 用于重试请求的重试对象。如果指定 None，则将使用默认配置重试请求。

  • timeout (float | None) – 等待请求完成的时间量（以秒为单位）。请注意，如果指定了 retry，则超时适用于每次单独的尝试。

  • metadata (collections.abc.Sequence[tuple[str, str]]) – 提供给方法的其他元数据。

list_notification_channels(project_id=PROVIDE_PROJECT_ID, format_=None, filter_=None, order_by=None, page_size=None, retry=DEFAULT, timeout=None, metadata=())[source]

获取通过 filter 参数传递的筛选器标识的所有通知渠道。

所需的返回类型可以通过 format 参数指定，支持的格式为 “dict”、“json” 和 None，它们分别返回 python 字典、字符串化的 JSON 和 protobuf。

参数

  • format – (可选) 结果的期望输出格式。支持的格式为 “dict”、“json” 和 None，它们分别返回 python 字典、字符串化的 JSON 和 protobuf。

  • filter – 如果提供此字段，则它会指定响应中包含的通知渠道必须满足的条件。有关更多详细信息，请参阅 https://cloud.google.com/monitoring/api/v3/sorting-and-filtering。

  • order_by (str | None) – 用于对结果进行排序的逗号分隔的字段列表。支持与 filter 字段相同的一组字段引用。条目可以添加减号前缀，以按降序对字段进行排序。有关更多详细信息，请参阅 https://cloud.google.com/monitoring/api/v3/sorting-and-filtering。

  • page_size (int | None) – 底层 API 响应中包含的最大资源数。如果每个资源执行页面流式传输，则此参数不会影响返回值。如果每个页面执行页面流式传输，则此参数确定页面中的最大资源数。

  • retry (google.api_core.retry.Retry | google.api_core.gapic_v1.method._MethodDefault) – 用于重试请求的重试对象。如果指定 None，则将使用默认配置重试请求。

  • timeout (float | None) – 等待请求完成的时间量（以秒为单位）。请注意，如果指定了 retry，则超时适用于每次单独的尝试。

  • metadata (collections.abc.Sequence[tuple[str, str]]) – 提供给方法的其他元数据。

  • project_id ( str ) – 从中获取通知渠道的项目。

enable_notification_channels(project_id=PROVIDE_PROJECT_ID, filter_=None, retry=DEFAULT, timeout=None, metadata=())[source]

启用由过滤器参数标识的一个或多个已禁用的警报策略。

如果策略已启用，则无效。

参数

  • project_id ( str ) – 需要启用通知渠道的项目。

  • filter – 如果提供此字段，则它会指定需要启用的通知渠道必须满足的条件。有关更多详细信息，请参阅 https://cloud.google.com/monitoring/api/v3/sorting-and-filtering。

  • retry (google.api_core.retry.Retry | google.api_core.gapic_v1.method._MethodDefault) – 用于重试请求的重试对象。如果指定 None，则将使用默认配置重试请求。

  • timeout (float | None) – 等待请求完成的时间量（以秒为单位）。请注意，如果指定了 retry，则超时适用于每次单独的尝试。

  • metadata (collections.abc.Sequence[tuple[str, str]]) – 提供给方法的其他元数据。

disable_notification_channels(project_id, filter_=None, retry=DEFAULT, timeout=None, metadata=())[source]

禁用由 filter 参数标识的一个或多个已启用的通知渠道。

如果策略已禁用，则无效。

参数

  • project_id ( str ) – 需要启用通知渠道的项目。

  • filter – 如果提供，则此字段指定要禁用的警报策略必须满足的条件。有关更多详细信息，请参阅 https://cloud.google.com/monitoring/api/v3/sorting-and-filtering。

  • retry (google.api_core.retry.Retry | google.api_core.gapic_v1.method._MethodDefault) – 用于重试请求的重试对象。如果指定 None，则将使用默认配置重试请求。

  • timeout (float | None) – 等待请求完成的时间量（以秒为单位）。请注意，如果指定了 retry，则超时适用于每次单独的尝试。

  • metadata (collections.abc.Sequence[tuple[str, str]]) – 提供给方法的其他元数据。

upsert_channel(channels, project_id, retry=DEFAULT, timeout=None, metadata=())[source]

创建新的通知或更新现有通知渠道。

渠道由 alerts 参数中的 name 字段标识。

参数
delete_notification_channel(name, retry=DEFAULT, timeout=None, metadata=())[source]

删除通知渠道。

参数

  • name ( str ) – 要删除的警报策略。格式为： projects/[PROJECT_ID]/notificationChannels/[CHANNEL_ID]。

  • retry (google.api_core.retry.Retry | google.api_core.gapic_v1.method._MethodDefault) – 用于重试请求的重试对象。如果指定 None，则将使用默认配置重试请求。

  • timeout (float | None) – 等待请求完成的时间量（以秒为单位）。请注意，如果指定了 retry，则超时适用于每次单独的尝试。

  • metadata (collections.abc.Sequence[tuple[str, str]]) – 提供给方法的其他元数据。

此条目是否有帮助？