打赏

相关文章

Apache Airflow 系列教程 | 第6课:DAG 解析与处理引擎

导读(Introduction) 欢迎来到 Apache Airflow 源码深度解析系列的第六课。 在前一课中,我们深入剖析了 Scheduler 的核心原理——它如何在循环中创建 DagRun、推进任务状态、将任务入队给 Executor。但 Scheduler 能调度 DAG 的前提是:系统必须先"看到"这些 DA…

Apache Airflow 系列教程 | 番外篇:通过 REST API 动态创建 DAG

导读(Introduction) 在 Apache Airflow 的标准使用模式中,DAG 的定义通常以 Python 文件的形式存放在 DAGs 文件夹中,由 DagFileProcessorManager 周期性解析并持久化到数据库。然而在实际的平台化场景中,用户往往希望通过 Web 界面或 API 接口以更友好的方式(如填写表单…

手机版浏览

扫一扫体验

微信公众账号

微信扫一扫加关注

返回
顶部