python - Docker 中的快速 API + Apache Airflow

Question

我想构建微服务，我将在其中拥有两个 docker 容器——Fast API 和 Apache Airflow。那么，我的问题是如何从某个 Fast API 端点提交一些新的 DAG？我想应该是 Airflow CLI ？或者是其他东西 ？

标签： pythondockerairflowfastapi

Answer 1

Apache Airflow 可以通过REST API和CLI进行管理。

但是，DAG 是 Python 文件，它们必须存储在 Airflow 可访问的文件系统上。无法通过 API 提交 DAG 脚本。

部署 DAG 有不同的方法。由于您使用的是容器，因此有两个选项是挂载您将 DAG 文件写入其中的卷，或者使用内置在映像中的 DAG 脚本构建映像并重新部署 Airflow。