气流中的牵引持续时间统计API

Question

在气流中，“甘特”图提供了一个相当好的性能方面的运行任务。它提供开始/结束时间、持续时间等统计数据。

你们知道通过气流API以编程方式提取这些数据的方法吗？我想使用这些统计数据，并生成关于我的任务的执行情况以及它如何随时间变化的定期报告。

我的气流版本是: 1.9 Python: 3.6.3在码头上运行

谢谢!开尔文

气流在线文档

Answer 1

一种简单的方法可以是建立SQL炼金术连接，一旦配置完成，气流存储/发送所有数据(dag/stat/fail，task info/stats/等等)。

编辑airflow.cfg并添加：

sql_alchemy_conn = mysql://------/table_name

Answer 2

根据文档，气流可以发送StatsD格式的指标，包括

dag.<dag_id>.<task_id>.duration -完成任务所需的秒时间

不幸的是，我没有看到像开始/结束时间度量那样的东西。