运行1次安装任务的最佳实践

Question

我经常遇到这样的情况：

resources

• Store

• 设置长期资源(如SQL表)或跳过(如果它已经存在

• )，请执行一些工作，在长期资源和清理临时资源(清理临时资源

)中创建临时

• 结果。

是否有一种气流方式或最佳做法来处理只运行一次的一次性任务？

Answer 1

您可以创建只运行一次的DAG，如下所示：

from airflow.models import DAG

dag = DAG(
    dag_id='my_one_time_dag',
    schedule_interval='@once'
)