在Airflow中,计划间隔是指任务的执行频率。以下是一个包含代码示例的解决方法:
from datetime import datetime, timedelta
from airflow import DAG
from airflow.operators.dummy_operator import DummyOperator
default_args = {
'owner': 'airflow',
'depends_on_past': False,
'start_date': datetime(2021, 1, 1),
'retries': 1,
'retry_delay': timedelta(minutes=5),
}
dag = DAG(
'example_dag',
default_args=default_args,
description='An example DAG',
schedule_interval=timedelta(days=1),
)
在上面的代码中,我们设置了DAG的默认参数,并指定了计划间隔为每天执行一次。
task1 = DummyOperator(task_id='task1', dag=dag)
task2 = DummyOperator(task_id='task2', dag=dag)
task1 >> task2
在上面的代码中,我们创建了两个DummyOperator任务,并使用>>
操作符将它们连接起来。这表示task2任务将在task1任务完成后执行。
dag = example_dag()
将上述代码保存为example_dag.py
文件,并将其放置在Airflow的DAG目录中。然后,您可以使用Airflow的命令行界面或Web界面来管理和运行该DAG。
请注意,上述代码示例仅用于演示目的,您可以根据自己的需求进行修改和扩展。