气流界面非常方便，可以查看气流DAG进度状态。
气流Rest API是另一种检查气流dag状态的方法，但它需要认证令牌。
我们可以从气流界面获取认证令牌，但如果气流界面宕机，则很难获取认证令牌和气流DAG状态。
是否有其他方法从后端检查/监控和清除任务实例(除了Rest API和气流UI) ?
我们已经根据此气流文档页面检查气流健康状态在气流健康检查端点上设置了状态检查。我们每5分钟运行一次无服务器功能，以检查metabase和scheduler的状态是否健康.
当气流下降时，您可以通过在无服务器功能中定义的另一个代码块直接将警报路由到Slack频道/Email/Opsgenie警报。
from airflow.models.dagrun import DagRun
from airflow.utils.state import DagRunState
dag_runs = DagRun.find(dag_id='the_dag_id_you_want_to_check')
last_run = dag_runs[-1]
print('the dag state is -->: ', last_run.state)