是否可通过REST API发送DAG文件内容创建Apache Airflow DAG

核心结论：Apache Airflow 原生官方REST API 不支持直接传递DAG文件内容来创建DAG。

原因说明 #

Airflow的DAG加载逻辑是固定扫描配置项dags_folder指定目录下的Python文件，解析文件内的DAG定义完成加载，没有提供将传入的文件内容直接写入DAG目录、触发解析的原生接口。你当前使用的查询DAG列表接口，本质是读取已经被Airflow扫描解析完成的DAG元数据，仅支持查询操作，不会触发任何DAG文件写入、创建动作。
你提到的查询DAG列表调用示例如下：

curl -u "admin:admin" http://localhost:8080/api/v1/dags

接口返回示例：

{
  "dags": [],
  "total_entries": 0
}

注意：不要尝试直接向Airflow元数据库写入DAG元数据记录，没有对应实体DAG文件的情况下，DAG调度、运行时会直接抛出异常，无法正常使用。

可落地的替代实现方案 #

• 自建中间接口层：对外暴露接收DAG文件内容的自定义API，收到内容后先做语法、逻辑合法性校验，再将内容写入所有Airflow调度节点、Worker节点对应的dags_folder目录，等待Airflow定时扫描（默认扫描间隔为5分钟，可通过配置项dag_dir_list_interval调整时长）即可识别到新DAG。
• 搭配对象存储+主动触发解析：Airflow 2.0+版本支持DAG序列化能力，可以将dags_folder对接S3、OSS等对象存储，自定义API收到DAG内容后直接写入对象存储对应路径，再调用Airflow CLI命令airflow dags reserialize主动触发DAG重新解析，无需等待定时扫描即可快速加载新DAG。
• 容器化部署适配：如果是K8s等容器化环境部署的Airflow，可通过自定义API操作DAG目录对应的持久化存储卷，将上传的DAG内容写入对应存储路径，后续逻辑和本地部署一致，最终实现“传DAG内容即创建”的效果，这部分逻辑需要自行开发，不属于Airflow原生API能力范畴。

内容的提问来源于stack exchange，提问作者Rodrigo