数据集成 DI Agent

能力说明

DI Agent 支持通过自然语言创建和管理单表离线、单表实时、整库离线、整库实时四类同步任务。无需逐项填写数据源、字段映射、调度策略等表单配置，只需描述同步需求，Agent 即可完成从意图理解到发布上线的全流程。主要能力包括：

• 自然语言建任务：用一句话描述同步需求（如"把 RDS 订单库整库实时同步到 Hologres，按天分区"），Agent 自动完成数据源识别、Schema 探测、字段映射、资源组分配和调度策略配置。

• 意图理解与多轮对话：Agent 能理解模糊或不完整的需求描述，通过追问补全关键参数（如分区策略、增量条件），确保生成的任务配置准确可用。

• 任务全生命周期管理：支持通过对话完成任务的编辑、暂停、恢复、删除和重跑，覆盖任务从创建到下线的完整生命周期。

• 批量任务操作：支持一次对话同时创建或修改多个同步任务，适用于整库迁移、批量调整调度策略等规模化场景。

使用示例

以下示例演示如何通过对话创建一个同步任务：

1. 进入 DI Agent 对话界面。

2. 输入同步需求，例如："把 RDS 订单库整库实时同步到 Hologres，按天分区"。

3. Agent 自动探测源端 Schema，展示待同步表清单，确认后继续。

4. Agent 自动完成字段映射、资源组分配和调度策略配置。

5. 预览任务配置摘要，确认无误后发布上线。

6. 查看任务运行状态，验证数据已正常同步。

能力说明

DI Agent 支持将大模型推理能力作为 ETL 算子嵌入数据流水线，对来源数据中的结构化数据，以及非结构化数据（图片、视频、音频、文档等）进行批量 AI 处理（识别、分类打标、转写、翻译、摘要、向量化等，以及自定义处理逻辑），处理结果直接写入所有数据集成支持去向（如 MaxCompute、Hologres 或 DLF 数据湖等），让各种数据得以合适的格式进入企业数据资产体系。主要能力包括：

• 自然语言定义处理逻辑：用自然语言描述处理意图（如"识别图片中的商品类别并输出标签"），Agent 自动生成对应的处理 Pipeline 配置。

• 三段式 Pipeline 编排：Agent 自动编排 Source → Transform（大模型推理）→ Sink 流水线，无需额外编写脚本或搭建推理服务。

• 结果直写各种目的端：比如处理结果直接写入 MaxCompute、Hologres 或 DLF 数据湖，无需额外搬运。

• 数据 Embedding：支持对处理后的数据进行向量化并写入指定存储端，便于后续 RAG 使用。

• 批量与周期运行：支持百万级文件的批量处理，可配置定时周期运行以持续增量处理新增数据。

使用示例

以下示例演示如何处理 OSS 中的商品图片并将结果写入 MaxCompute：

1. 进入 AI 数据处理功能入口。

2. 输入处理需求，例如："读取AWS S3 bucket 下的商品图片 → 调用大模型识别分类标签 → 结果写入 MySQL 表"。

3. Agent 自动编排三段式 Pipeline：Source（S3）→ Transform（大模型推理）→ Sink（MySQL）。

4. ChatDB 自动识别目标表，生成对应 SQL。

5. 查看返回的图表结果（折线图/柱状图等自动匹配）。

6. 若需要对特征工程数据库中的数据，进行Embedding向量化至Hologres中，以便做RAG使用。可以用自然语言定义Embedding："继续做Embedding → 调用大模型进行向量化 → 结果写入 Hologres 表"。

7. Agent 自动编排三段式 Pipeline：Source（MySQL）→ Transform（大模型向量化）→ Sink（Hologres）。

8. ChatDB 自动识别目标表，生成对应 SQL。

9. 查看返回的结果。

查询数据源库表结构及业务含义

ChatDB 支持通过自然语言探索数据库元数据并解读业务含义。指定目标数据源后，Agent 自动连接并逐层展开库、表、字段的完整结构信息，包括表名、字段类型、主外键关系、索引约束等元数据细节。Agent 还会结合表名、字段命名及数据特征解读库表的业务含义，帮助快速理解每张表的用途、字段代表的业务概念及表间关联关系。

适用场景：新接手陌生系统需要快速了解数据全貌，以及跨团队协作时非技术人员需要理解数据结构。

数据源样例数据预览

ChatDB 支持通过自然语言查看任意表的样例数据。指定目标表后，Agent 自动拉取具有代表性的数据样本并加以说明，无需编写 SQL 即可直观确认表中存储的数据内容和格式。

适用场景：快速验证数据内容、了解字段实际取值，以及帮助非技术人员在跨团队协作中理解数据含义。

统计分析图表展示

ChatDB 支持自然语言驱动的数据分析与可视化。描述分析意图（例如"查看最近三个月各品类的销售趋势"或"对比各区域的订单占比"），Agent 自动定位数据源、生成查询逻辑，并将分析结果以折线图、柱状图、饼图等图表形式呈现，无需编写 SQL 或使用专业可视化工具。

适用场景：业务人员快速验证经营假设，以及技术团队排查问题时即时获取趋势数据。

库表结构诊断与优化建议

ChatDB 支持智能诊断指定数据源的库表结构。Agent 自动扫描目标数据库的表结构设计，从命名规范、字段类型选择、索引覆盖、主外键完整性、冗余字段、分区策略等维度审查，识别潜在的设计缺陷，并给出具体的优化建议和改进方向。

适用场景：新建库表的设计评审、存量系统的技术债务梳理，以及数据库性能问题的根因排查。

数据库性能排查和优化

ChatDB 支持数据库性能诊断与慢 SQL 根因分析。描述性能问题或指定目标数据源后，Agent 自动分析导致查询缓慢的各类因素，包括全表扫描、索引失效、JOIN 顺序不合理、子查询嵌套过深、数据类型隐式转换、统计信息过期、锁竞争与热点表等常见性能瓶颈，并结合实际执行计划说明每条慢 SQL 的根因，给出索引调整、查询改写、表结构重构等针对性优化建议。

适用场景：线上突发性能故障的应急排查，以及日常巡检中对潜在慢查询的主动治理。

能力说明

收到同步任务告警后，可在 Agent 对话界面描述问题或粘贴告警信息，Agent 自动聚合任务日志、资源监控指标、源端数据库状态等多维度信息，定位根因并给出修复方案，将排障时长从小时级缩短到分钟级。每次诊断结果自动归档为知识库条目，下次同类问题直接匹配已有解法，不因人员轮换而从零排查。主要能力包括：

• 多维信息聚合：自动采集并关联任务日志、资源监控指标、源端数据库状态、网络带宽等多维度信息，在一个视图内呈现完整上下文。

• 根因定位：基于聚合信息自动分析故障根因（如 CU 不足、源端锁表、网络带宽瓶颈、配置错误等），给出明确结论。

• 修复方案推荐与一键执行：定位根因后给出可操作的修复建议（扩容资源组、重启实例、调整并发度等），确认后支持一键执行。

• 经验自动沉淀：每次诊断结果自动归档为知识库条目，下次同类问题直接匹配已有解法。

使用示例

1. 告警触发后，进入 Agent 对话界面，描述问题或粘贴告警信息。

2. Agent 自动聚合任务日志、资源监控指标、源端状态等多维信息。

3. Agent 输出根因分析报告（如：CU 不足导致消费速率低于生产速率）。

4. Agent 给出修复方案建议（如：扩容资源组 CU 配额或重启失败实例），确认后执行修复。

能力说明

DI Agent 提供由 AI Agent 创建和管理的自动化智能巡检任务。无需编写监控脚本或配置告警规则，创建巡检任务并开启自动调度后，Agent 即按运行频率主动巡检同步任务的运行状态，并在每次运行完成后生成结果详情报告，将运维模式从被动响应转为主动治理。主要能力包括：

• 可配置运行频率：运行频率按 Cron 表达式配置，支持一次性、每小时、每天、每周、每月与自定义 Cron，默认每天 08:00。开启自动调度前必须先配置运行频率。

• 全量链路主动扫描：Agent 按周期自动扫描全量同步链路的运行状态，主动发现潜在风险，无需人工逐项检查。

• 结果详情报告：巡检完成后生成结果详情报告，可在任务的运行记录中查看当次报告，报告支持新窗口打开与下载，便于在团队内流转和归档。

• 优先级排列与操作建议：高风险任务按影响范围和紧急程度排列优先级，每项附带具体操作建议和预期收益评估。

使用示例

1. 登录数据集成控制台，在左侧导航栏AI Native下单击智能巡检任务。

2. 创建巡检任务。单击新建智能巡检任务，在下拉菜单中选择通过 Agent 聊天创建或手动创建；也可以直接单击页面上方推荐场景卡片，使用内置场景模板快速创建。手动创建时需填写任务名称、描述、资源组、运行频率与任务内容（以自然语言描述巡检内容）。

3. 开启自动调度后，Agent 按运行频率自动执行巡检；也可以在任务列表中通过更多 > 立即执行手动触发一次巡检。

4. 在任务的运行记录页面查看每次运行的状态与结果详情报告，报告支持新窗口打开与下载。

能力说明

巡检解决的是周期性体检，值守解决的是异常发生当下的实时响应。值守以场景为管理单元，一个场景是一组事件的集合：先定义场景适用的任务类型，再在场景内配置监控事件与各自的触发阈值，应用到具体任务后还可以针对单个任务单独覆盖阈值。任务命中事件时，Agent 自动收集运行信息、分析原因，并持续跟踪任务的恢复情况。主要能力包括：

• 内置值守场景：提供实时同步延迟值守、实时同步运行值守、离线同步运行值守三类内置场景，可直接应用到符合适用类型的同步任务。

• 事件级阈值管理：一个场景可配置多个监控事件，每个事件独立设定触发阈值；应用到任务后支持按单个任务覆盖阈值，实现重点任务的精细化调整。

• 触发即分析：业务延迟持续超限时，自动分析源端、同步链路与目标端，定位可能的性能瓶颈；任务运行失败或频繁发生容灾切换（Failover）时，自动分析异常原因；离线同步任务或离线增量实例执行失败时，自动收集运行信息并给出处理建议。

• 恢复跟踪与值守记录：完成分析后持续跟踪任务的恢复情况；每次触发的事件沉淀为一条值守记录，展示触发时间、命中事件的任务、命中的具体事件、分析结论与当前是否已恢复，形成可回溯的运维台账。