from datetime import datetime
from airflow import DAG
from airflow.utils import timezone
LOCAL_TZ = ‘Asia/Shanghai’
default_args = {
'owner': 'airflow',
'depends_on_past': False,
'start_date': datetime(2020, 1, 1, tzinfo=timezone.utc)
}
dag = DAG('example_dag', default_args=default_args, schedule_interval='@daily', timezone=LOCAL_TZ)
[core]
default_timezone = Asia/Shanghai
airflow resetdb && airflow initdb && airflow scheduler
请注意,使用以上命令将会清空您的 Airflow 元数据库,请务必提前备份好需要保留的信息。