sql 查询 apache 气流

Question

我想直接查询 apache airflow 数据库以获取失败任务的报告，但我正在为在数据库中进行适当的连接而苦苦挣扎。

我想要的是由以下列组成的输出

dag_run.dag_id dag_run.run_id dag_run.state dag_run.conf task_instance.task_id task_id.state

基本上是所有 dag_runs 及其任务状态的 sql 转储；类似于 'Graph' 视图，但全部 run_ids.

谢谢！

Answer 1

这里是查询失败任务的相关信息。

SELECT dr.dag_id, dr.run_id, dr.state, dr.conf, ti.task_id, ti.state
FROM dag_run as dr
INNER JOIN
(
    SELECT dag_id, task_id, state, execution_date
    FROM task_instance
    WHERE state = 'failed'
) as ti
ON dr.dag_id = ti.dag_id AND dr.execution_date = ti.execution_date

我不知道你想要什么，但是你可以使用 DAG 的 on_failure_callback 参数来设置它在失败时做一些事情。我推荐使用这个方法。

sql 查询 apache 气流

sql query for apache airflow

sql

airflow