| 12345678910111213141516171819 |
- """
- Airflow的第一个DAG
- """
- from airflow import DAG
- from airflow.operators.bash_operator import BashOperator
- from datetime import datetime
- default_args = {
- "owner": "ryan.miao",
- "start_date": datetime(2019, 9, 1)
- }
- dag = DAG("Hello-World",
- description="第一个DAG",
- default_args=default_args,
- schedule_interval='0 8 * * *')
- t1 = BashOperator(task_id="hello", bash_command="echo 'Hello World, today is {{ ds }}'", dag=dag)
|
