airflow - 有没有办法提取 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 提取这些字段并通过电子邮件发送?
解决方案
推荐阅读
- oauth - 从具有文件夹限制的应用程序(如 Dropbox)中使用 Google Drive
- database - 使用 Redis 进行实时聊天 - 如何不丢失消息?
- c - 如何画一个圆?
- python - 使用 pandas json_normalize 将 json 转换为数据框,但有些列仍然有我需要转换的列表
- c - 为什么临时指针指向 0 而不是 3?
- algorithm - Bittorent Rarest First 算法 - 如何选择作品?
- angular - 将数据传递给与属性选择器一起使用的子组件
- python - 如何裁剪张量的某些部分?
- php - laravel 中的查询返回空响应
- python - 将熊猫数据框导出到csv时如何保持前导0?