首页 > 解决方案 > 有没有办法提取 Last run (date) ,最后从 Airflow 过期的 DAG 并通过电子邮件发送

问题描述

我正在寻找从 Last Run , Last Expired Date of a DAG 检查 DAG 状态(成功/失败)的手动过程自动化。

目前,我们的 DAG 计划按时运行

Current hour - 2hrs .

问题:有时调度程序停止并且作业开始失败。为避免这种情况,我需要设置并发送电子邮件,其中将提供有关 DAG 成功及其 Last Run 和 last Expired 字段的信息。

我检查了这些字段在mysql(气流数据库)中是否可用;下数据库:气流表:dag。

有没有办法可以通过 Airflow UI 或 mysql 提取这些字段并通过电子邮件发送?

标签: airflow

解决方案


推荐阅读