ThinkingAI Logo

AE 数据开发

通过 ae-cli 操作 AE 数据开发平台——数据仓库管理、流程编排、IDE SQL 查询、数据集成与同步,让数据工程从"手动网页操作"升级为"命令行全流程驱动"。

数据采集数据采集数据工程数据工程全行业
返回 Skills 库

AE DataOps Skill 是 ThinkingAI 行业 Skill 库中的一项数据开发与运维能力,帮助数据工程团队通过 ae-cli 命令行工具操作 AE 数据开发平台——空间发现、数据表与视图管理、流程编排(创建/调度/发布/监控)、IDE SQL 查询、数据集成与同步,6 大模块覆盖数据开发全生命周期,从"手动在网页上逐个操作数据任务"升级为"命令行全流程驱动"的高效模式。这正是 ThinkingAI「10 年行业经验沉淀为开箱即用 Skill」的体现。

Agent
ae-dataops
最近报表越跑越慢,「过去 30 天付费用户」这段逻辑我印象里到处都在重复算。帮我扫一遍到底有多少地方在重复,该沉淀的沉淀成中间表,再配上每天自动更新的任务流。
IDE 扫描全空间报表 SQL,检索重复逻辑
「过去 30 天付费用户」CTE 被 13 张报表重复引用
评估膨胀影响 — 追踪引用该 CTE 的下游任务耗时
标签计算已从 30 分钟膨胀至 4 小时 02 分
DEV 创建增量中间表 dws_pay_user_30d,每日只回刷新增付费明细
创建任务流 flow_pay_user_30d,CRON 配 0 0 2 * * ?(每日 02:00)
预览发布到 PROD,手动触发首跑
首跑成功,耗时 4 分 12 秒
改写查询频次最高的 3 张报表引用中间表并回测
单表查询 2–4 分钟 → 5–8 秒

治理完成,根因比预想的集中。「过去 30 天付费用户」这段 CTE 被 13 张报表各算各的,现已沉淀为中间表 dws_pay_user_30d、挂上每日任务流——已改写的报表查询从 2–4 分钟降到 5–8 秒,标签计算切换后预计从 4 小时回到 15 分钟以内。

一、任务流状态

任务流调度最近执行耗时状态
flow_pay_user_30d(本次新建)每日 02:00(0 0 2 * * ?)今日 14:32 手动首跑4 分 12 秒已上线 PROD
flow_user_tag(标签计算)每日 03:00今日 03:004 小时 02 分已改写引用,明日生效
flow_mysql_sync(数据同步)每日 01:00今日 01:0011 分 40 秒正常
flow_report_ads(报表加工)每日 05:00今日 05:0026 分 18 秒已改写引用,明日生效
← 左右滑动查看

二、本次治理动作

扫描全空间报表 SQL,确认「过去 30 天付费用户」CTE 被 13 张报表重复引用——同一段口径每天被全量重算 13 遍,是慢的公共根因
在 DEV 建增量中间表 dws_pay_user_30d:每日只处理当日新增付费明细,不再重算 30 天全量窗口
新建任务流并配 6 字段 CRON 0 0 2 * * ?,预览发布到 PROD,首跑 4 分 12 秒成功
已改写查询频次最高的 3 张报表与标签任务流的引用;其余 10 张报表已列成切换清单,建议按查询频次分两批完成
结论
这次治理的本质,是把散在 13 处的同一段业务口径收敛成一份有调度、有监控、有唯一出处的数据资产。后续新报表要用付费用户口径,直接引用 dws_pay_user_30d,别再手写 CTE——口径漂移比慢查询更难排查。
任务流 flow_pay_user_30d 已上线,每日 02:00 自动更新,失败告警已挂接运维监控。

行业痛点

数据开发是数据体系的基础工程,但超过 60% 的数据工程团队在开发效率上存在瓶颈:创建一个数据流程需要手动配置 SQL 任务节点、依赖关系、调度规则和 CRON 表达式,平均耗时 30 分钟;流程执行后的运维更困难,排查一个失败任务平均耗时 15-20 分钟;数据集成配置需要手写 JSON 且文档分散,错误率超过 40%。

核心价值

  • 6 大模块全覆盖:repo(空间发现)+ datatable(表/视图管理)+ flow(流程编排)+ operations(运维监控)+ ide(SQL 查询)+ integration(数据集成)
  • 6 个场景路由:流程创建、流程监控、数据集成、数据查询、表管理、空间发现,自动匹配用户意图
  • 流程生命周期完整:DEV 配置→预览发布→PROD 手动执行→运维排查,每步有对应命令
  • ID 系统清晰:executeId(早期停止句柄)vs flowInstanceId(稳定运维句柄),不同场景用不同 ID
  • CRON 6 字段规范:秒 分 时 日 月 周(比标准 5 字段多一个"秒"字段),常见模板直接可用

适用场景

1

需要创建数据流程(添加 SQL 任务节点、配置依赖和调度、发布到 PROD)

2

需要监控流程执行状态、查看任务日志、停止异常实例

3

需要创建数据源和配置数据同步方案

4

需要在 IDE 中执行 SQL 查询或浏览数据表结构

5

需要创建数据表或视图并发布到 PROD

6

需要发现可用的 DataOps 空间和空间代码

实战案例

某数据工程团队 · 每日同步流程批量创建
团队每日需要创建 3 个数据同步流程(MySQL→AE、ClickHouse→AE、Databricks→AE),手动配置每个流程平均 30 分钟。通过 AE DataOps Skill,系统先 +list_spaces 发现空间,再创建 DEV 流程、添加 SQL 任务节点、配置依赖和 CRON(0 0 2 * * ?),预览发布到 PROD。3 个流程从手动配置 90 分钟缩短至命令行批量执行 15 分钟,CRON 格式错误率从 40% 降至零。

常见疑问

DEV 和 PROD 有什么区别?

DEV 是开发环境,负责创建/修改任务和配置调度;PROD 是生产环境,负责正式执行和运维排查。所有创建和修改操作在 DEV 完成,通过预览发布到 PROD。

CRON 格式为什么是 6 字段?

AE DataOps 使用秒 分 时 日 月 周的 6 字段格式,比标准 5 字段多一个"秒"字段。常见模板如 `0 0 2 * * ?` 表示每日凌晨 2 点。

和 ae-analysis 有什么区别?

ae-analysis 是分析侧操作(报表/看板/Ad-hoc 查询),ae-dataops 是数据开发侧操作(流程编排/SQL 开发/数据同步)。前者查数据,后者建数据。

相关 Skills 推荐

用「AE 数据开发」武装你的 Agent

预约演示,看看它如何在你的业务场景中落地

ThinkingAI Big Logo
电话咨询