如何上传已激活状态的Airflow DAG?
如何上传DAG时直接设置为激活状态
有三种常用方法可以实现上传DAG时自动激活,无需手动操作:
在DAG代码中显式设置参数
定义DAG时添加is_paused_upon_creation=False参数,这是最灵活的方式,仅针对当前DAG生效。示例代码:from airflow import DAG from datetime import datetime with DAG( dag_id="my_active_dag", start_date=datetime(2024, 1, 1), schedule_interval="@daily", is_paused_upon_creation=False, # 开启后上传即激活 catchup=False ) as dag: # 这里编写你的任务逻辑Airflow默认该参数为
True,改为False后,DAG被系统解析后会直接处于激活状态。修改Airflow全局默认配置
如果希望所有新上传的DAG都默认激活,可以修改Airflow的核心配置文件airflow.cfg:[core] dags_are_paused_at_creation = False修改后需要重启Airflow的webserver和scheduler服务,后续新上传的所有DAG都会自动激活。
用CLI命令自动化激活
可以把激活命令加入到你的DAG上传脚本中,上传完成后自动执行:airflow dags unpause <你的DAG_ID>这种方式适合不想改动代码或全局配置的场景,通过脚本完成上传+激活的自动化流程。
内容的提问来源于stack exchange,提问作者recalde_ricardo
相关产品推荐
相关产品推荐

