airflow - 了解 Airflow 中的“无”调度预设
问题描述
我开始使用 Apache Airflow 并尝试在 Airflow 中设置事件驱动的 DAG。我的事件是一个文件登陆 Linux 目录。该文件可以在一天中多次登陆。我正在使用文件传感器操作员进行文件监控。
我的要求是每次文件在目录中登陆(同名)时,Dag 应该启动。
我正在阅读官方调度文档,根据我的理解,我看到选项无我可以使我的 Dag 根据事件在外部触发,并且可以根据该外部事件在一天中多次触发。
我的理解正确吗?官方文档没有关于它的详细信息。
https://airflow.apache.org/scheduler.html?highlight=scheduling
解决方案
那是对的。使用 schedule_intervalNone
意味着 Airflow 永远不会自动安排 Dag 的运行。
您可以通过几种不同的方式在外部安排 dag_runs:
- 通过气流 CLI
- 在 python 脚本中使用本地客户端
- 通过气流 REST API
- 通过 Web UI 中的触发按钮手动进行
推荐阅读
- python - 分页自定义 Json
- c - 当我删除 c = getchar() 部分时,为什么默认语句在案例之后起作用?
- c - 计数器变量问题
- java - 如何从 MediaStore 获取一些歌曲数据?
- arrays - 如何在邮递员中分解正文请求 - 使用 laravel
- linux - 如何在c ++中修复对...的未定义引用
- python - 更改时间和 NonExistentTimeError:2019-03-31 01:50:24.455000
- django - 如何在环境变量中设置django路径?
- java - 使用文件编写器类型转换问题
- python - 如何在我的类中继承 QtWidgets.QWidget 并使我的类类型 - QtWidgets.QWidget?