Airflow 模块

此功能处于测试阶段，可能随时更改。其设计和代码不如正式 GA 功能成熟，按现状提供，不提供任何担保。测试版功能不受正式 GA 功能支持 SLA 的约束。

此模块收集来自Airflow 指标的指标。它运行一个 statsd 服务器，Airflow 将向其发送指标。默认 metricset 为statsd。

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

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

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

[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' ]

以下 metricsets 可用