要通过Airflow发送指标到StatsD，可以使用Airflow的自定义指标记录器（metric reporter）。以下是一个示例解决方案：

1. 首先，安装statsd库：

pip install statsd

2. 创建一个自定义指标记录器类，继承BaseRecorder类并实现record方法：

from airflow.stats import BaseRecorder
import statsd

class StatsDRecorder(BaseRecorder):
    def __init__(self, statsd_host, statsd_port):
        self.statsd_client = statsd.StatsClient(statsd_host, statsd_port)

    def record(self, metric_name, value, tags=None):
        # 将指标发送到StatsD
        self.statsd_client.gauge(metric_name, value, tags=tags)

3. 在Airflow配置中启用自定义指标记录器，并传入StatsD的相关信息：

# airflow.cfg

[scheduler]
statsd_on = True
statsd_host = localhost
statsd_port = 8125
statsd_prefix = airflow

4. 在Airflow的启动脚本中创建自定义指标记录器实例，并将其传递给Airflow的Stats实例：

from airflow.stats import Stats
from my_custom_recorder import StatsDRecorder

recorder = StatsDRecorder(statsd_host='localhost', statsd_port=8125)
Stats.set_global_instance(Stats(recorder=recorder))

这样，Airflow的指标将被记录并发送到StatsD。请注意，这只是一个示例解决方案，你可能需要根据你的具体需求进行修改和调整。