编辑“︁Airflow Web服务器”︁（章节）

= Airflow Web服务器 =

== 介绍 ==  
'''Airflow Web服务器'''是Apache Airflow的核心组件之一，提供了一个基于Web的用户界面（UI），用于监控、管理和调试工作流（DAGs）。它允许用户直观地查看DAG的运行状态、任务日志、任务依赖关系以及执行历史记录。Web服务器通过REST API与Airflow的元数据库交互，实时反映调度器的状态。

== 主要功能 ==  
Airflow Web服务器提供以下关键功能：  
* '''DAG可视化'''：以图形化方式展示DAG的结构和任务依赖关系。  
* '''任务管理'''：手动触发、暂停或重试任务。  
* '''日志查看'''：直接访问任务执行的日志，便于调试。  
* '''变量与连接配置'''：管理Airflow的全局变量和外部系统连接。  
* '''权限控制'''：支持基于角色的访问控制（RBAC）。  

== 启动Web服务器 ==  
通过以下命令启动Web服务器（默认端口8080）：  
<syntaxhighlight lang="bash">  
airflow webserver --port 8080  
</syntaxhighlight>  

=== 参数说明 ===  
* <code>--port</code>：指定服务端口（默认8080）。  
* <code>--hostname</code>：绑定到特定主机（默认0.0.0.0）。  

== 用户界面详解 ==  

=== DAG视图 ===  
DAG列表页显示所有已注册的DAG，包含以下信息：  
* '''状态标识'''（成功、失败、运行中）。  
* '''调度间隔'''（如<code>@daily</code>）。  
* '''最近执行时间'''。  

点击DAG名称进入详情页，可查看：  
* '''Graph View'''：可视化DAG依赖关系（使用Mermaid语法示例）：  
<mermaid>  
graph TD  
    A[Task1] --> B[Task2]  
    B --> C[Task3]  
</mermaid>  
* '''Code View'''：直接查看DAG的Python源码。  

=== 任务实例管理 ===  
在任务实例页面，用户可以：  
1. 手动触发任务：  
<syntaxhighlight lang="bash">  
airflow tasks run <dag_id> <task_id> <execution_date>  
</syntaxhighlight>  
2. 清除任务状态以重新运行。  

== 实际案例 ==  

=== 场景：监控ETL流水线 ===  
假设有一个每日运行的ETL DAG，Web服务器可用于：  
1. 检查某天任务失败原因（通过日志）。  
2. 手动重跑失败任务。  
3. 分析任务执行时间（通过甘特图视图）。  

=== 代码示例：通过API访问Web服务器 ===  
Airflow Web服务器暴露REST API，以下示例使用<code>curl</code>获取DAG列表：  
<syntaxhighlight lang="bash">  
curl -X GET http://localhost:8080/api/v1/dags  
</syntaxhighlight>  
输出示例（JSON格式）：  
<syntaxhighlight lang="json">  
{  
  "dags": [  
    {"dag_id": "example_etl", "is_paused": false},  
    {"dag_id": "data_cleanup", "is_paused": true}  
  ]  
}  
</syntaxhighlight>  

== 高级配置 ==  

=== 安全加固 ===  
* 启用HTTPS：通过反向代理（如Nginx）配置SSL。  
* 认证方式：支持OAuth、LDAP或自定义认证（通过<code>airflow.cfg</code>配置）。  

=== 性能优化 ===  
* 设置<code>worker_class</code>为<code>gevent</code>以提高并发能力。  
* 使用缓存（如Redis）加速UI响应。  

== 常见问题 ==  

'''Q: Web服务器无法启动，提示端口被占用？'''  
A: 更换端口或终止占用进程：  
<syntaxhighlight lang="bash">  
lsof -i :8080 && kill <PID>  
</syntaxhighlight>  

'''Q: 如何自定义UI中的DAG颜色？'''  
A: 在DAG定义中添加<code>ui_color</code>参数：  
<syntaxhighlight lang="python">  
default_args = {  
    'ui_color': '#FF0000',  # 红色  
}  
</syntaxhighlight>  

== 总结 ==  
Airflow Web服务器是管理和监控工作流的核心工具，适合从初学者到高级用户的所有人群。通过UI或API，用户可以高效地调试任务、分析性能并确保数据管道的可靠性。

[[Category:大数据框架]]
[[Category:Airflow]]
[[Category:Airflow基础]]