Airflow for Mac 工作流管理平台完全指南

在终端中，首先设置 Airflow 的家目录（推荐使用项目专用目录）。

1. 打开终端（Terminal），创建并进入你的项目目录：
   
   mkdir ~/airflow_projects/my_workflow && cd ~/airflow_projects/my_workflow
2. 设置环境变量（可写入 ~/.zshrc 持久化）：
   
   export AIRFLOW_HOME=~/airflow_projects/my_workflow
3. 初始化 Airflow 的元数据库：
   
   airflow db init
4. 创建管理员用户（用于登录 Web UI）：
   
   airflow users create --username admin --firstname Admin --lastname User --role Admin --email admin@example.com
   按提示设置密码。

1. 在新的终端窗口或标签页中，启动 Web 服务器：
   
   airflow webserver --port 8080
2. 再打开一个新的终端窗口或标签页，启动调度器：
   
   airflow scheduler
3. 此时，在浏览器中访问 http://localhost:8080，使用步骤 1 创建的用户名和密码登录，即可看到 Web UI。

在 AIRFLOW_HOME 目录下，创建 dags 文件夹（如果不存在）：mkdir dags。

使用任何文本编辑器或 IDE（如 VS Code）在 dags 文件夹内创建一个 Python 文件，例如 my_first_dag.py。以下是一个简单的示例：

from datetime import datetime
from airflow import DAG
from airflow.operators.bash import BashOperator

with DAG(
    dag_id='my_first_dag',
    start_date=datetime(2023, 10, 1),
    schedule_interval='@daily',
    catchup=False
) as dag:

    task1 = BashOperator(
        task_id='print_date',
        bash_command='date'
    )

    task2 = BashOperator(
        task_id='echo_hello',
        bash_command='echo "Hello from Airflow!"'
    )

    task1 >> task2  # 定义依赖关系：task1 先执行，然后 task2
    

保存文件。Airflow 调度器会自动扫描 dags 文件夹并加载该 DAG。

1. 刷新 Web UI 的 DAGs 列表页面，稍等片刻即可看到 my_first_dag 出现。
2. 点击 DAG 名称进入详情页。
3. 在 DAG 详情页，点击右上角的 “开关”按钮（位于 DAG ID 右侧）以激活（unpause）该 DAG。激活后，调度器会根据 schedule_interval 自动调度运行。
4. 若要立即手动触发一次运行，点击 “Trigger DAG” 按钮（带播放图标）。
5. 在“树状图”或“图表”视图中，可以观察任务实例的状态变化（如 queued, running, success, failed）。

1. 在树状图或图表视图中，点击一个任务实例（如 print_date）的方块。
2. 在弹出的菜单中，选择 “Log”。
3. 日志页面将显示该任务实例执行时的标准输出和错误信息，这是排查任务失败原因的主要途径。

• 重试失败任务：在任务实例菜单中，选择 “Clear”。这将清除该实例的状态，调度器会重新将其排队执行。
• 标记任务为成功/失败：在任务实例菜单中，选择 “Mark Success” 或 “Mark Failed”。用于手动干预工作流状态，跳过或强制失败某个任务。