要在Windows服务器上执行Airflow任务,您可以按照以下步骤操作:
airflow version
from airflow import DAG
from airflow.operators.bash_operator import BashOperator
from datetime import datetime
default_args = {
'owner': 'airflow',
'start_date': datetime(2022, 1, 1)
}
dag = DAG('my_dag', default_args=default_args, schedule_interval=None)
task = BashOperator(
task_id='my_task',
bash_command='python C:/path/to/your_script.py',
dag=dag
)
task
在上面的示例中,我们使用BashOperator
来运行一个命令,该命令将在Windows服务器上执行Python脚本your_script.py
。
保存上述代码为一个Python文件(例如my_dag.py
)。
在Windows服务器上使用以下命令启动Airflow调度程序:
airflow scheduler
airflow webserver
访问Web浏览器,输入Airflow Web服务器的URL(默认为http://localhost:8080
),您将在Airflow Web界面中看到您创建的DAG。
在Airflow Web界面中,将DAG切换到“On”状态,然后点击“Trigger DAG”按钮来触发任务执行。
您可以在Airflow Web界面的“Graph View”和“Tree View”中查看任务的执行状态和日志。
以上步骤提供了一个基本的示例,您可以根据自己的需求和任务来修改和扩展。