airflow.providers.datadog.sensors.datadog¶

类¶

DatadogSensor

一个用于监听 Datadog 事件流并过滤，以确定是否发出了某些事件的传感器。

模块内容¶

class airflow.providers.datadog.sensors.datadog.DatadogSensor(*, datadog_conn_id='datadog_default', from_seconds_ago=3600, up_to_seconds_from_now=0, priority=None, sources=None, tags=None, response_check=None, **kwargs)[source]¶

基类: airflow.sensors.base.BaseSensorOperator

一个用于监听 Datadog 事件流并过滤，以确定是否发出了某些事件的传感器。

依赖于 Datadog API，该 API 必须部署在运行 Airflow 的同一台服务器上。

参数:

datadog_conn_id (str) – Datadog 连接，包含 API 密钥的元数据。
from_seconds_ago (int) – POSIX 时间戳开始 (默认 3600)。
up_to_seconds_from_now (int) – POSIX 时间戳结束 (默认 0)。
priority (str | None) – 事件优先级，低 (low) 或正常 (normal)。
sources (str | None) – 逗号分隔的列表，指示（如果存在）应使用哪些标签来按范围过滤监视器列表
tags (list[str] | None) – 从特定来源获取 Datadog 事件。
response_check (Callable[[dict[str, Any]], bool] | None) – 对 ‘requests’ 响应对象的检查。该可调用对象将响应对象作为第一个位置参数，并可选地接受上下文字典中可用的任意数量的关键字参数。对于‘通过’应返回 True，否则返回 False。
response_check – Callable[[dict[str, Any]], bool] | None

ui_color = '#66c3dd'[source]¶

datadog_conn_id = 'datadog_default'[source]¶

from_seconds_ago = 3600[source]¶

up_to_seconds_from_now = 0[source]¶

priority = None[source]¶

sources = None[source]¶

tags = None[source]¶

response_check = None[source]¶

poke(context)[source]¶

派生此类时重写此方法。