SuperAPI AI 工具集

airflow

测试与质量

查看项目

更新于 10-15 23:46

技能介绍

用途:使用 af 命令行工具查询、管理和排查 Apache Airflow 工作流,包括列出 DAG、触发运行、读取任务日志、诊断失败等。

主要能力:af 提供 DAG 操作(af dags list/get/explore/source/pause/unpause/errors/warnings/stats)、运行操作(af runs list/get/trigger/trigger-wait/delete/clear/diagnose)、任务操作(af tasks list/get/instance/logs)、配置查询(af config version/show/connections/variables/pools/plugins/providers/assets)、直接 REST API 访问(af api)以及 Registry 发现(af registry providers/modules/parameters/connections)。命令默认输出 JSON,可用 jq 过滤。

使用方式:命令假设 af 在 PATH 中,可通过 astro otto 运行,或用 uv tool install astro-airflow-mcp 独立安装。支持多实例配置(af instance add/list/use/current/delete/discover),配置分层类似 git(全局、项目共享、项目本地),令牌可用 ${VAR} 引用环境变量,也可直接用 AIRFLOW_API_URL、AIRFLOW_AUTH_TOKEN 等环境变量或 CLI 标志。

本地运行与部署:推荐 Astro CLI,astro dev init 初始化项目,astro dev start 启动本地 Airflow(webserver 在 http://localhost:8080),astro dev parse 解析 DAG 捕获错误,astro dev pytest 运行测试,astro deploy 或 astro deploy --dags 部署。

适用场景:DAG 查询与探索、运行触发与监控、失败诊断与日志查看、系统健康检查、API 端点探索、编写 DAG 前查询 operator 签名。

限制:af instance discover 非 dry-run 模式会在 Astro Cloud 创建 API 令牌,属敏感操作,需先 --dry-run 预览并获用户同意。Registry 结果本地缓存,最新版本 1 小时、固定版本 30 天。资料未提供收费、价格或平台支持等更多信息。