airflow - 如何检查 Airflow 调度程序的健康状况和状态？

Question

我已经用 postgreSSQL 数据库配置了 apache-airflow，在我的 Airflow 中我运行了 1 个 dag，现在它运行成功但是如果调度程序有任何问题意味着我如何得到它以及检查它的方法是什么，请提供一些想法和解决方案。

Answer 1

• Airflow 暴露 /health endpoint为此目的
• 同时检查 REST API reference ，它有许多有用的端点，可用于一些常见的日常事务，如 triggering a DAG或返回 latest runs of DAGs

---

UPDATE-1

显然只是因为 scheduler 正在运行，并不一定意味着它实际上会触发 DAG；例如this

• 你可以把它想象成 Airflow 可能存在内部错误/有趣的损坏内部状态，这可能会导致它不触发 DAG
• 因此人们提前了一步，他们安排了一个canary DAG (一个虚拟的 DAG，它什么都不做，每隔几分钟运行一次)。然后通过监控金丝雀 DAG 的指标(想想 prometheus)，他们可以可靠地确认 Airflow 调度程序是否按预期工作。