Airflow 模块

此功能为 Beta 版，可能会发生更改。其设计和代码不如正式 GA 功能成熟，按原样提供，不提供任何保证。Beta 功能不受正式 GA 功能的支持 SLA 约束。

此模块从 Airflow 指标收集指标。它运行一个 statsd 服务器，airflow 将指标发送到该服务器。默认指标集为 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' ]

以下指标集可用