编辑“︁Airflow与Grafana集成”︁（章节）

=== 自定义指标 ===  
通过PythonOperator注入自定义指标：  
<syntaxhighlight lang="python">  
from airflow.operators.python import PythonOperator  
from statsd import StatsClient  

def track_custom_metric(**context):  
    statsd = StatsClient()  
    statsd.incr('custom.metric')  

task = PythonOperator(  
    task_id='log_metric',  
    python_callable=track_custom_metric  
)  
</syntaxhighlight>