在Airflow / MWAA中设置start_date,需要使用Python Datetime对象并在dag定义中设置default_args属性。下面是一个示例代码:
from datetime import datetime
from airflow import DAG
from airflow.operators.dummy import DummyOperator
default_args = {
'owner': 'airflow',
'start_date': datetime(2021, 9, 1),
'retries': 0
}
with DAG('example_dag',
default_args=default_args,
schedule_interval='@daily') as dag:
start = DummyOperator(task_id='start')
end = DummyOperator(task_id='end')
start >> end
在上面的代码中,datetime(2021, 9, 1)指定了start_date为2021年9月1日。这个值可以根据需要进行更改。一旦设置了start_date,您可以编写其余的DAG代码并在Airflow / MWAA中运行它。
上一篇:Airflow/minio: 我如何将minio用作Airflow发送的数据的本地S3代理?
下一篇:Airflow1.10.10的调度程序执行时出现“ErrorfetchingCelerytaskstate”的错误。