mcpField
A
airflow

airflow

github.com/necatiarslan数据与数据库4447 次安装21 周前更新
代码仓库

关于 airflow

airflow 是用于 Airflow 运维的技能，指导通过 Airflow VS Code 扩展管理 DAG、运行和配置，并排查失败任务。

主要功能

  1. 01查看及暂停、恢复 DAG
  2. 02触发并查看 DAG 运行
  3. 03分析失败运行与日志
  4. 04查看连接、变量和服务器健康状态

适用场景

  1. 01检查运行中的 DAG 和近期失败
  2. 02触发 DAG 后跟踪运行状态
  3. 03调查失败运行及其任务日志

安装

复制下面的命令，在终端中运行。

$npx skills add https://github.com/necatiarslan/airflow-vscode-extension --skill airflow

安装后在 Claude Code 中输入/airflow确认已加载。

详细介绍

Airflow 运维

所有 Airflow 交互都使用 Airflow VS Code 扩展工具。避免使用 shell 命令执行 Airflow 操作。

工具速查

工具用途
list_active_dags列出已启用（未暂停）的 DAG
list_paused_dags列出已暂停的 DAG
get_running_dags显示正在运行或排队中的 DAG 运行
pause_dag暂停 DAG
unpause_dag恢复 DAG
trigger_dag_run触发 DAG 运行
get_dag_runs列出某个 DAG 的运行记录
get_dag_history查看某个 DAG 的每日运行历史
get_failed_runs查看所有 DAG 的失败运行
analyse_dag_latest_run全面分析最近一次运行（任务、日志、源代码）
get_dag_run_detail全面分析指定的运行
get_dag_source_code获取 DAG 源代码
go_to_dag_view打开 DAG 视图面板
go_to_dag_log_view打开日志视图面板
go_to_connections_view打开连接面板
go_to_variables_view打开变量面板
go_to_providers_view打开提供程序面板
go_to_configs_view打开配置面板
go_to_plugins_view打开插件面板
go_to_server_health_view打开服务健康状态面板

用户意图示例

DAG 操作
  • “列出所有 DAG” -> list_active_dags 和 list_paused_dags
  • “显示 DAG 源代码” -> get_dag_source_code
  • “暂停 DAG X” -> pause_dag
  • “恢复 DAG X” -> unpause_dag
运行操作
  • “触发 DAG X” -> trigger_dag_run
  • “显示最近的运行记录” -> get_dag_runs
  • “为什么运行失败了？” -> analyse_dag_latest_run 或 get_dag_run_detail
日志与故障排查
  • “显示任务日志” -> go_to_dag_log_view 或 analyse_dag_latest_run
  • “分析最近一次运行” -> analyse_dag_latest_run
系统与配置
  • “显示连接” -> go_to_connections_view
  • “显示变量” -> go_to_variables_view
  • “检查服务健康状态” -> go_to_server_health_view

常见工作流

调查失败的运行
  1. 查找失败记录：get_failed_runs
  2. 分析最近一次运行：analyse_dag_latest_run
  3. 如果已知具体运行 ID：get_dag_run_detail
  4. 如有需要，打开日志：go_to_dag_log_view
触发并监控
  1. 触发运行：trigger_dag_run
  2. 检查状态：get_dag_runs
  3. 如果失败，进行分析：analyse_dag_latest_run
每日晨间健康检查
  1. 检查服务健康状态：go_to_server_health_view
  2. 检查正在运行的 DAG：get_running_dags
  3. 查看近期失败记录：get_failed_runs

评论

支持 Markdown