airflow.providers.datadog.hooks.datadog¶

类¶

DatadogHook

使用 Datadog API 发送几乎所有可衡量事物的指标。

模块内容¶

class airflow.providers.datadog.hooks.datadog.DatadogHook(datadog_conn_id='datadog_default')[source]¶

基类：airflow.hooks.base.BaseHook, airflow.utils.log.logging_mixin.LoggingMixin

使用 Datadog API 发送几乎所有可衡量事物的指标。

可以跟踪数据库记录插入/删除的数量、从文件读取的记录以及许多其他有用的指标。

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

参数：: datadog_conn_id (str) – Datadog 连接，包含 API 密钥的元数据。

conn_name_attr = 'datadog_conn_id'[source]¶

default_conn_name = 'datadog_default'[source]¶

conn_type = 'datadog'[source]¶

hook_name = 'Datadog'[source]¶

api_key[source]¶

app_key[source]¶

api_host[source]¶

source_type_name[source]¶

host[source]¶

validate_response(response)[source]¶

验证 Datadog 响应。

send_metric(metric_name, datapoint, tags=None, type_=None, interval=None)[source]¶

发送单个数据点指标到 Datadog。

参数：

metric_name (str) – 指标名称
datapoint (float | int) – 与指标相关的单个整数或浮点数
tags (list[str] | None) – 与指标关联的标签列表
type – 指标类型：gauge (仪表), rate (比率), or count (计数)
interval (int | None) – 如果指标类型是 rate 或 count，定义相应的间隔

query_metric(query, from_seconds_ago, to_seconds_ago)[source]¶

查询 Datadog 获取一个指标，可能应用了某些函数，并返回结果。

参数：

query (str) – 要执行的 Datadog 查询（参见 Datadog 文档）
from_seconds_ago (int) – 开始查询的时间点（距现在多少秒之前）。
to_seconds_ago (int) – 查询截止的时间点（距现在多少秒之前）。

post_event(title, text, aggregation_key=None, alert_type=None, date_happened=None, handle=None, priority=None, related_event_id=None, tags=None, device_name=None)[source]¶

向 Datadog 发布事件（处理完成、潜在警报、其他问题）。

将其视为维护警报持久性的方式，而不是警报本身。

参数：

title (str) – 事件标题
text (str) – 事件正文（更多信息）
aggregation_key (str | None) – 可用于在流中聚合此事件的键
alert_type (str | None) – 事件的警报类型，可选值：[“error” (错误), “warning” (警告), “info” (信息), “success” (成功)]
date_happened (int | None) – 事件的 POSIX 时间戳；默认为现在
handle (str | None) – str
priority (str | None) – 发布事件的优先级。（“normal” (正常) 或 “low” (低)，默认为“normal”）
related_event_id (int | None) – 作为给定事件的子事件发布
tags (list[str] | None) – 要应用于事件的标签列表
device_name (list[str] | None) – 发布事件时使用的 device_name

Handle：

发布事件的用户；默认为用于提交的应用程序密钥所有者。

classmethod get_connection_form_widgets()[source]¶

返回要添加到连接表单的连接小部件。

classmethod get_ui_field_behaviour()[source]¶

返回自定义字段行为。