可以在DAG文件中设置schedule_interval参数来指定任务的调度频率。例如,以下示例中的DAG将每天执行一次任务:
from datetime import datetime, timedelta
from airflow import DAG
from airflow.operators.bash_operator import BashOperator
default_args = {
'owner': 'airflow',
'depends_on_past': False,
'start_date': datetime(2021, 1, 1),
'retries': 1,
'retry_delay': timedelta(minutes=5),
}
dag = DAG('my_dag', default_args=default_args, schedule_interval=timedelta(days=1))
t1 = BashOperator(
task_id='my_task',
bash_command='echo "Hello World!"',
dag=dag
)
schedule_interval=timedelta(days=1)
参数将任务设置为每天执行一次。如果要更改调度频率,请更改此参数的值。例如,更改schedule_interval=timedelta(minutes=30)
为每30分钟执行一次。