Airflow 模块

Airflow 模块编辑

此功能处于测试阶段，可能会有所更改。设计和代码不如官方 GA 功能成熟，按原样提供，不提供任何保证。测试版功能不受官方 GA 功能支持 SLA 的约束。

此模块从 Airflow 指标收集指标。它运行一个 statsd 服务器，Airflow 将向该服务器发送指标。默认指标集是 statsd。

Airflow 模块已在 Airflow 2.1.0 上测试。它应该适用于版本 2.0.0 及更高版本。

Airflow 模块需要 Statsd 来接收 statsd 指标。有关如何使用 statsd 的说明，请参阅链接。

将以下行添加到您的 Airflow 配置文件（例如 airflow.cfg）中，确保 statsd_prefix 保持为空，并用 Metricbeat 运行的地址替换 %METRICBEAT_HOST%

[metrics]
statsd_on = True
statsd_host = %METRICBEAT_HOST%
statsd_port = 8126
statsd_prefix =

Airflow 模块支持模块中描述的标准配置选项。以下是一个示例配置

metricbeat.modules:
- module: airflow
  host: "localhost"
  port: "8126"
  #ttl: "30s"
  metricsets: [ 'statsd' ]

以下指标集可用