Airflow允许用户通过设置schedule_interval
参数来自定义调度间隔。schedule_interval
可以是一个时间表达式、一个cron表达式或一个timedelta
对象。
以下是一些常见的schedule_interval
设置示例:
from datetime import datetime, timedelta
from airflow import DAG
default_args = {
'start_date': datetime(2021, 1, 1),
'retries': 3,
'retry_delay': timedelta(minutes=5)
}
dag = DAG(
'my_dag',
default_args=default_args,
schedule_interval='@daily'
)
from datetime import datetime, timedelta
from airflow import DAG
default_args = {
'start_date': datetime(2021, 1, 1),
'retries': 3,
'retry_delay': timedelta(minutes=5)
}
dag = DAG(
'my_dag',
default_args=default_args,
schedule_interval='@hourly'
)
from datetime import datetime, timedelta
from airflow import DAG
default_args = {
'start_date': datetime(2021, 1, 1),
'retries': 3,
'retry_delay': timedelta(minutes=5)
}
dag = DAG(
'my_dag',
default_args=default_args,
schedule_interval='0 10 * * 1-5'
)
from datetime import datetime, timedelta
from airflow import DAG
default_args = {
'start_date': datetime(2021, 1, 1),
'retries': 3,
'retry_delay': timedelta(minutes=5)
}
dag = DAG(
'my_dag',
default_args=default_args,
schedule_interval='0 0 1 * *'
)
from datetime import datetime, timedelta
from airflow import DAG
default_args = {
'start_date': datetime(2021, 1, 1),
'retries': 3,
'retry_delay': timedelta(minutes=5)
}
dag = DAG(
'my_dag',
default_args=default_args,
schedule_interval=timedelta(minutes=5)
)
这些示例展示了不同的schedule_interval
设置方式,您可以根据自己的需求选择适合的设置。