开源大数据平台E-MapReduce：EMR AI助手功能介绍

连接真实集群，而非通用问答

AI助手直接连接您的StarRocks实例与Serverless Spark工作空间，可读取系统表、查询Profile、监控指标、作业日志与队列资源等运行时数据。所有诊断和建议基于集群的真实状态生成，而非基于通用知识的泛化回答。

从被动应答到主动运维

AI助手不仅在您提问时工作。通过配置智能日报、巡检报告和告警推送（含Spark巡检日报、Spark Workspace定期巡检等），AI助手可7×24持续监控集群状态，主动发现问题并推送到钉钉/飞书，无需人工值守。

多入口覆盖，随时可用

支持通过EMR控制台、钉钉/飞书IM通道、API接口多种方式接入，融入您现有的运维工作流，无需切换工具。

对话窗口

控制台内置的AI对话界面，支持与AI助手进行多轮对话交互。

• 支持自然语言提问，AI助手自动识别意图并连接集群进行分析。

• 支持上下文多轮对话，可在一次会话中逐步深入排查问题。

• 对话历史自动保存，可随时回顾之前的诊断记录。

• 支持选择关联实例，对不同实例不同场景进行分析。

• 支持在Serverless StarRocks与Serverless Spark之间切换产品，针对不同产品进行问答与诊断。

• 支持选择专家技能，一键调用专项诊断流程。StarRocks内置性能诊断、开发助手、运维管理、湖仓排障四类专家技能，Spark内置作业诊断、运维管理两类专家技能。

任务中心

管理AI助手的定时任务和历史执行记录，支持按产品维度（Serverless StarRocks / Serverless Spark）分别查看和管理任务。

任务配置：

• 配置智能日报的推送时间和频率。

• 配置巡检报告的执行周期。

• StarRocks内置3项定时任务（全量健康巡检、运行中SQL巡检、历史慢SQL巡检）和6项告警任务（CheckPoint异常告警、Compaction异常告警、机器负载异常告警、Routine Load异常告警、物化视图异常告警、查询延迟异常告警）。

• Spark内置5项系统定时任务（Spark Workspace定期巡检、Spark巡检日报推送、Spark慢任务专家、Spark失败作业诊断汇总、Spark队列资源巡检）。

• 支持启用/暂停，支持设置触发阈值。

执行记录：

• 查看所有任务的历史执行结果。

• 查看每次日报/巡检/告警的完整内容。

• 按时间、类型、状态筛选记录。

• 执行失败时可查看失败原因。

IM配置

将AI助手接入企业IM工具，团队成员在工作群内即可直接使用。

• 支持钉钉、飞书、企业微信接入。

• 配置对应群组的Webhook地址和签名密钥。

API/SDK对接

支持通过API/SDK，将EMR AI助手能力内置于您的企业平台和自动化运维流程中，详情请参见通过API调用EMR AI助手。

性能诊断

当集群出现延迟飙升、查询超时、资源打满等问题时，AI助手可快速定位根因并给出修复方案。

集群运维

覆盖日常巡检、弹性伸缩、配置管理等运维操作。

异常排查

主动运维

AI助手可按计划自动执行分析任务，并将结果推送到IM通道。

所有定时任务和推送记录均可在任务中心中查看和管理。

咨询答疑

作业诊断

当Spark作业出现耗时超预期、执行失败、性能劣化等问题时，AI助手可快速定位原因并给出优化建议。

运维管理

覆盖资源诊断、工作空间巡检等日常运维操作。

主动运维

AI助手可按计划自动执行Spark分析任务，并将结果推送到IM通道。

所有Spark定时任务和推送记录均可在任务中心中查看和管理。