编写一个airflow py文件,每天执行
时间: 2024-01-25 09:02:54 浏览: 134
这里是一个简单的 Airflow DAG 示例,它将每天执行一个 Python 脚本:
```python
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(2022, 1, 1),
'email': ['airflow@example.com'],
'email_on_failure': False,
'email_on_retry': False,
'retries': 1,
'retry_delay': timedelta(minutes=5),
}
dag = DAG(
'daily_script',
default_args=default_args,
description='Run a Python script every day',
schedule_interval=timedelta(days=1),
)
t1 = BashOperator(
task_id='run_script',
bash_command='python /path/to/your/script.py',
dag=dag,
)
t1
```
在这个例子中,我们创建了一个名为 `daily_script` 的 DAG,它将每天执行一次一个名为 `run_script` 的 BashOperator 任务。这个任务将执行一个 Python 脚本,该脚本的路径是 `/path/to/your/script.py`,您需要将其替换为您自己的脚本路径。
要使用此 DAG,您需要将其保存为一个 Python 文件,然后将该文件放在您的 Airflow DAG 目录中。在这个目录中,Airflow 将自动扫描并加载这些 DAG 文件,并在其计划时间到达时执行它们。请确保您已经启动了 Airflow 调度程序和工作程序,并且已经启用了 DAG。
阅读全文