AI 同步生成器 功能定位 AI 同步生成器根据白名单源表、字段注释和业务描述,生成 SeaTunnel 同步候选配置。它把“从哪张表同步到哪张 ODS 表、保留哪些字段、按什么方式增量”写成结构化候选,但不会自动执行。 图 7-6 自然语言输入、候选草稿与源字段说明 适用角色 ETL 管理员、集成开发人员和数据开发人员。 页面入口 数据治理中心 → AI 数据助手 → AI 同步生成器( /bi/etl/ai/sync)。 前置条件 AI 服务正常,当前演示环境使用 DeepSeek-V4.1-Flash。 目标源表在服务端白名单内,并已完成元数据采集。 DolphinScheduler 登记通道可用,当前账号有 AI 流水线权限。 操作步骤 选择服务端模板,例如“销售订单全量同步”。 选择白名单源表,页面会加载字段名、类型和中文注释。 填写方案标题和业务描述。描述应说明同步频率、目标 Schema、需要保留的字段和过滤条件。 点击“AI 生成候选流水线”,等待返回草稿编号、模型名和候选内容。 在“结构化预览”检查源表、目标表、字段映射、主键和增量策略;必要时切换“JSON 编辑”修正白名单内字段。 点击“确定性校验”,处理阻断错误和告警。 提交人工审核,审核通过后绑定内容摘要;最后“登记发布”到 DolphinScheduler 门禁。 发布后仍需按正常同步流程执行和核对数据。 输入与输出 项目 说明 输入 模板、白名单源表、方案标题、最多 1200 字业务描述 输出 同步候选草稿、字段映射、校验结果、审核记录、版本和发布摘要 状态 待校验、已校验、已审核、已发布、已驳回 宏澜家电示例 业务描述:“每天 02:00 把销售订单增量同步到 Doris ODS,保留订单金额、状态、客户、产品和更新时间,已取消订单也保留以便审计。”AI 生成订单源表到 ods_sales_order 的候选映射;数据开发补充增量字段后校验、审核并登记调度。 客户应用演示:让 AI 起草订单同步作业 业务情境: 数据开发需要新增订单同步,但希望先生成标准配置草稿。 第一步:进入“数据治理中心 → AI数据助手 → AI 同步生成器” 步骤图 40-01 第1步:进入“数据治理中心 → AI数据助手 → AI 同步生成器”。红框标出进入数据治理中心 → AI数据助手 → AI 同步生成器。 进入“数据治理中心 → AI数据助手 → AI 同步生成器”。 第二步:选择订单源表和目标 ODS 表 步骤图 40-02 第2步:选择订单源表和目标 ODS 表。红框标出选择订单源表和目标 ODS 表。 选择订单源表和目标 ODS 表,填写同步频率、增量字段和业务说明。 第三步:点击生成 步骤图 40-03 第3步:点击生成。红框标出点击生成。 点击生成,查看源字段、目标字段、过滤条件和安全边界。 第四步:执行确定性校验 步骤图 40-04 第4步:执行确定性校验。红框标出执行确定性校验。 执行确定性校验,修正字段类型、主键和白名单问题。 第五步:保存为草稿并提交审核 步骤图 40-05 第5步:保存为草稿并提交审核。红框标出保存为草稿并提交审核。 保存为草稿并提交审核;审核发布后才交给调度执行。 最终结果与效果 生成符合固定模板的同步草稿,包含字段映射、批次和安全配置;不会自动执行或改写生产数据。 操作提示: AI 草稿必须经过校验和人工审核;不要用自然语言要求绕过白名单。 常见问题 生成失败或超时。 检查 AI 服务状态、描述长度和源表字段;不要重复提交十几次,先看页面错误信息。 选择不到源表。 表不在白名单或元数据未采集。 修改 JSON 后不能发布。 修改会重置校验和审核,必须重新校验、重新审核。 开发人员参考 接口: /bi/ai-pipeline/status、 /options?kind=SYNC、 /generate、 /drafts、 /drafts/{id}/validate|review|publish 权限: bi:etl:ai-sync 大模型只能选择模板和字段,不能生成任意连接串或执行任意组件。 发布只登记固定摘要门禁,不直接执行模型产物;内容 SHA-256 与审核记录绑定。