菜单
Aqueduct SQL 审查模式启动入口。 DO trigger when 用户要求审查 SQL 变更、对比线上 SQL 和变更版本、 提到"审查 SQL"、"对比线上版本"、"review SQL"、"aqueduct review"、 "SQL 变更校验"。 Do NOT trigger for 从需求文档开发新 SQL（使用 /data-developer）、 交付后的需求变更（使用 /change-management）、仅校验 SQL 规范（使用 aqueduct validate）。
用 Codex 或 Claude 帮你安装 复制这段 Prompt，粘贴到 Codex、Claude 或其他助手里，让它检查 Skill 页面并帮你完成安装。
基于 SOC 职业分类
Aqueduct 数据开发自动化全流程执行技能（默认模式）。 从需求文档出发，在单次对话中自动完成需求澄清、表结构设计、ETL SQL开发、 代码审查、DQC质量保障、交付沉淀六步闭环。 DO trigger when 用户提供需求文档要求开发SQL（默认首选此技能）、 自然语言描述数据开发需求（如"帮我开发这个需求"、"从需求生成SQL"、 "数据开发"、"SQL开发"、"ETL开发"、"需求转SQL"）、 发送需求文档路径。 DO NOT trigger when 用户明确要求 CLI/管道模式（此时用 /aqueduct-dev）、 仅查询表结构/血缘/API、仅做SQL规范校验、通用编程问题。
Aqueduct CLI 管道启动入口。仅在用户明确要求 CLI/管道模式时触发。 DO trigger when 用户明确提到"CLI"、"管道"、"pipeline"、"aqueduct dev"命令、 "走一遍管道"、"跑 CLI"、"用项目代码跑"、"用我的SQL跑一遍"、"我有现成的SQL"。 DO NOT trigger when 用户只是自然语言描述数据开发需求（此时应由 /data-developer 处理）。 如果用户提供了 SQL 文件且要求走管道，使用 `--sql-file` 参数跳过 LLM 生成。 Do NOT trigger for 仅查询表结构/血缘/API、仅做SQL规范校验、 通用编程问题、变更管理（使用 /change-management）。
Aqueduct 数据开发自动化框架调用入口。 DO trigger when 用户提到"数据开发"、"SQL开发"、"数仓开发"、"数据管道"、 "表结构设计"、"数据质量测试"、"DA设计"、"aqueduct"、"需求转SQL"、"ETL开发"。 默认路由到 /data-developer（插件直接生成模式），除非用户明确要求 CLI 管道模式。 Do NOT trigger for 仅查询数据血缘/上下游依赖、仅查询现有API/数据源/离线任务详情、 讨论非数仓相关的通用编程问题。
需求变更管理技能。管理数据开发交付后的需求变更，确保变更可追溯、可审查、可回滚。 DO trigger when 业务方提出新增字段、修改逻辑、删除字段等需求变更， 用户提及"变更"、"新增字段"、"改逻辑"、"加指标"、"需求变了"、"CR"等关键词， 或对比新旧需求文档发现差异时。 Do NOT trigger for 首次开发（使用 data-developer）、仅审查已有SQL（使用审查模式）。
| name | aqueduct-review |
| description | Aqueduct SQL 审查模式启动入口。 DO trigger when 用户要求审查 SQL 变更、对比线上 SQL 和变更版本、 提到"审查 SQL"、"对比线上版本"、"review SQL"、"aqueduct review"、 "SQL 变更校验"。 Do NOT trigger for 从需求文档开发新 SQL（使用 /data-developer）、 交付后的需求变更（使用 /change-management）、仅校验 SQL 规范（使用 aqueduct validate）。 |
| allowed-tools | ["Read","Write","Edit","Grep","Glob","Bash(python *)","Bash(pip *)","Bash(aqueduct *)","Bash(ls output/*)","Bash(dir output/*)","mcp__dp-asset-mcp__*"] |
| tags | ["data-engineering","code-review","sql","entry-point"] |
| version | 1.0.0 |
你是 Aqueduct 审查管道的执行者。你的职责是：确保环境就绪 → 启动审查管道 → 展示审查结果。
审查模式对比线上版本和变更版本，自动完成差异分析、逻辑校验、DQC 测试、审查报告。
验证虚拟环境已激活且 aqueduct 已安装：
python -c "import aqueduct; print(f'aqueduct {aqueduct.__version__}')"
如果失败：
source .venv/bin/activate（Windows: .venv\Scripts\activate）pip install -e ".[dev]"需要两个 SQL 文件：
online.sql — 线上版本（当前生产环境运行的 SQL）changed.sql — 变更版本（用户修改后的 SQL）可选：-d 参数描述变更意图（如"新增客户过滤条件"）
aqueduct review {online.sql} {changed.sql} -d "{变更描述}"
管道自动执行：需求理解 → 差异比对 → 代码审查 → DQC 测试 → 审查报告
管道完成后，读取输出目录的审查报告，向用户展示：
| 文件 | 说明 |
|---|---|
Phase5-{name}_审查报告.md | 代码审查结果（Critical/Warning/INFO） |
Phase5-数据质量测试.sql | 针对变更的 DQC 测试用例 |
Phase5-质量仪表盘.md | 质量覆盖率 |
Phase6-交付总报告.md | 审查总结 |
重点关注审查报告中的 Critical 和 Warning 级别问题，逐一解读给用户。