Byted Emr Skills

EMR Skills

• 何时使用（触发短语）
• 当用户提出以下任何类似需求时，立即调用该技能：

  “查询EMR集群的服务列表”
  “重启Spark服务”
  “获取 EMR 作业日志”
  “查看EMR serverless队列列表”
  “查看EMR serverless队列详情”
  “使用 EMR Serverless 运行任务”
  “在 EMR 上提交一个 Spark 作业”
  “帮我诊断一下失败的 Spark 作业”
  “分析一下EMR作业失败的原因”

• 任何涉及 EMR Serverless 作业/队列/计算组/监控/日志/诊断 的操作询问

功能清单

• EMR Serverless
  • 队列：开通公共队列、队列列表查询、队列详情查询、队列下计算组列表查询
  • 队列权限：查询队列授权主体、为用户授予/修改队列权限
  • 计算组：创建/修改/启动/停止/删除、查询可选规格与镜像、外部元数据连通性测试
  • 作业模板：创建/更新/查询详情/列表查询/运行
  • 作业实例：提交（SparkSQL/PrestoSQL/SparkJar/PySpark/RayJob）、查询状态与详情、取消、获取 tracking url、获取提交日志与执行日志、列表查询、重跑、结果分批拉取
  • 监控：队列/计算组/作业监控数据查询，按指标清单逐项拉取并汇总报告
• EMR Agent
  • 交互式诊断与知识问答
  • 会话与报告管理
• EMR on ECS
  • 集群：查看集群详情、集群列表、更新集群属性
  • 节点组：列出节点组、更新节点组属性、节点列表、扩容节点组磁盘、更新节点组ECS规格
  • 服务：列出应用、组件列表、组件实例列表、执行应用操作
  • 服务配置：配置文件列表、配置文件详情、配置项列表、配置项修改历史列表、修改配置项
  • 操作审计：操作列表查询
  • 用户：创建集群用户、修改已创建用户信息、获取集群用户列表、获取用户详情、更新集群用户密码
  • 用户组：获取集群用户组列表、集群用户组详情、创建集群用户组、更新集群用户组
• EMR on VKE
  • 集群：查看集群列表、集群详情
  • 服务（应用）：查看服务列表、服务组件实例、重启服务或组件实例、查看服务配置参数、修改服务配置参数
  • 操作日志：查看操作日志列表、操作日志详情

Initial Setup

• 确保已配置火山引擎 API 凭证：

export VOLCENGINE_AK="your-access-key"
export VOLCENGINE_SK="your-secret-key"
export VOLCENGINE_REGION="cn-beijing"

• 安装emr serverless sdk，调用scripts/bin/install_serverless_sdk.sh安装

How to manage EMR

1. EMR on Serverless管理

• 针对全托管的 Serverless 形态，主要面向作业提交和资源队列管理。
• OpenAPI 推荐使用命令行工具：python ./scripts/on_serverless/emr_serverless_cli.py --action <Action> --method <GET|POST> --query '<json>' --body '<json>'
  • Region 默认从环境变量 VOLCENGINE_REGION 读取（默认 cn-beijing）
  • Service/Version 会根据 Action 自动推断（需要时也可显式传 --service/--version）
  • 自定义 endpoint（如 LAS）可额外传 --endpoint las.cn-beijing.volcengineapi.com
• 作业提交推荐使用命令行工具：python ./scripts/on_serverless/emr_serverless_submit_cli.py <sql|jar|pyspark|ray> ...

如何管理资源队列

• 支持的功能列表
  • 队列列表：查看所有资源队列及其配置（如最大资源、当前使用量）, 必须使用OpenAPIListTagQueue查询队列列表。
  • 队列详情：获取队列的详细信息，包括绑定的网络、存储等, 必须使用OpenAPIGetQueue查询队列详情。
  • 队列监控：通过云监控接口获取队列近一天的资源使用率、作业数、失败作业数量等（需要云监控权限）。
  • 创建队列：一键创建公共队列, 必须使用OpenAPICreateQueueSilently或CreateOrderInOneStep创建队列。
  • 队列计算组列表：获取指定队列下的计算组（Queue Component）列表与详情，必须使用OpenAPIListQueueComponent查询队列计算组列表。
• 所有的队列功能操作详情，请严格按照references/emr_serverless/queue/emr_serverless_queue_guide.md中的说明进行操作。

如何管理队列权限

• 支持的功能列表
  • 获取队列权限列表：根据指定的队列，获取具有其权限的用户/用户组列表, 必须使用OpenAPIListAuthorizedPrincipalsForQueue查询队列权限列表。
  • 模糊搜索队列权限：根据用户名模糊查询用户列表，同时判断用户是否已经具有指定队列的权限，必须使用OpenAPIListIAMUsersWithQueueRole查询队列权限列表。
  • 添加用户权限：为用户授予指定数据对象的权限，必须使用OpenAPIGrantQueuePrivilege添加用户权限。
  • 修改用户的队列权限：修改用户对指定队列的权限, 必须使用OpenAPIAlterQueuePrivilege修改用户权限。
• 所有的功能操作详情，请严格按照references/emr_serverless/privilege/emr_serverless_privilege_guide.md中的说明进行操作。

如何管理作业模板

• 必须注意作业模板和作业实例的区别：
  • 作业模板：定义作业的通用配置，包括代码路径、参数、环境变量等。
  • 作业实例：基于作业模板创建的具体运行实例，包含作业 ID、运行参数、状态等。
• 支持的作业模板功能列表
  • 创建作业模板：定义作业模板（包含代码路径、参数、环境配置等），必须使用OpenAPICreateJobDefinition创建作业模板。
  • 执行或运行作业模板：基于已有作业模板触发一次运行，必须使用OpenAPIRunJobDefinition执行作业模板。
  • 修改作业模板：修改作业模板（如执行资源、代码路径、入口命令等），但不影响已提交的作业实例，必须使用OpenAPIAlterJobDefinition修改作业模板。
  • 查询作业模板详情：获取作业模板的详细配置信息，必须使用OpenAPIGetJobDefinition查询作业模板详情。
  • 查询作业模板列表：获取所有已创建的作业模板列表，必须使用OpenAPIListJobDefinitions查询作业模板列表。
• 所有作业模板（即作业定义）的详细操作指南，请严格按照references/emr_serverless/job/emr_serverless_job_guide.md中的说明进行操作。

如何管理作业实例

• 作业实例功能列表
  • 提交作业：支持 SparkSQL、PrestoSQL、SparkJar、PySpark、RayJob 等类型；SparkJar/PySpark/RayJob 支持作业执行脚本使用本地路径（由 SDK 自动上传至 TOS，细节见作业实例指南）。
  • 查询作业实例：推荐使用 OpenAPI QueryGetJobV2 获取状态与详情。
  • 终止作业实例：OpenAPI QueryCancelQueryV2。
  • 获取作业日志：OpenAPI FetchDriverLog / QueryFetchSubmitLog（支持关键字过滤）。
  • 分批获取结果数据：对于 SQL 类作业，可通过OpenAPI QueryFetchResultsByBatch 分批获取结果
  • 获取 Tracking url：OpenAPI QueryGetTrackingURL。
  • 作业实例列表：OpenAPI ListJobInstances。
• 所有作业实例的详细操作指南，请严格按照references/emr_serverless/job_instance/emr_serverless_job_instance_guide.md中的说明进行操作。

如何管理计算组（Serverless 资源单元）

• 创建/修改计算组配置。
• 查询计算组监控数据，支持监控总结和巡检。

如何查询操作日志

• 功能列表
  • 全局操作日志页面以及队列、计算组的操作列表查询
• 所有的操作日志查询，请严格按照references/emr_serverless/operation_audit/emr_serverless_operation_audit_guide.md中的说明进行操作。

如何查询队列、计算组、作业监控数据

• 功能列表
  • 队列计算组作业监控数据查询：获取队列、计算组、作业的监控数据，包括 CPU 利用率、内存利用率、作业数、失败作业数量等，必须使用OpenAPIGetMetricData查询队列、计算组、作业监控数据。
• 所有的队列计算组作业监控数据查询操作，请严格按照references/emr_serverless/monitor/emr_serverless_monitor_guide.md中的说明进行操作。

2. EMR Agent（EMR AI 助手）

如何进行交互式问题诊断和知识助手

• 功能列表
  • 适用于所有 EMR 形态，提供交互式问题诊断和知识问答。

如何管理诊断会话和报告管理

• 功能列表
  • 报告列表：获取历史诊断报告列表。
  • 查看报告详情：获取已有报告内容。
  • 会话列表：获取分析诊断和问答历史会话列表。
  • 查看会话详情：获取会话的详细信息，包括问题描述、回答内容、会话状态等。
• 所有分析诊断会话和报告操作，请严格按照references/emr_agent/emr_agent_guide.md中的说明进行操作。

3. EMR on ECS 集群管理

• 支持对基于 ECS 的传统 Hadoop 集群进行全生命周期管理。

如何管理集群

• 功能列表
  • 查看集群详情：获取集群基础信息、状态、计费类型、访问地址等，必须使用OpenAPIGetCluster查询集群详情。
  • 集群列表：按条件筛选、分页查询，必须使用OpenAPIListClusters查询集群列表。
  • 更新集群属性：修改集群名称、描述等，必须使用OpenAPIUpdateClusterAttribute更新集群属性。
• 所有集群管理操作详情，请严格按照references/emr_on_ecs/cluster/emr_on_ecs_cluster_guide.md中的说明进行操作。

节点组管理

• 功能列表
  • 列出节点组：查看集群内的节点组（如 Master、Core、Task）及其配置，必须使用OpenAPIListNodeGroups列出节点组列表。
  • 更新节点组属性：修改节点组名称、实例规格（支持升级）、磁盘扩容，必须使用OpenAPIUpdateNodeGroupAttribute更新节点组属性。
  • 节点列表：查看节点组内所有 ECS 实例的详细信息，必须使用OpenAPIListNodes查询节点组内所有节点实例的详细信息。
  • 扩容节点组磁盘：扩容指定节点组的磁盘容量，必须使用OpenAPIResizeNodeGroupDisk扩容节点组磁盘。
  • 更新节点组ECS规格：修改指定节点组的ECS实例规格，必须使用OpenAPIUpdateNodeGroupEcsSpec更新节点组ECS规格。
• 所有节点组管理操作详情，请严格按照references/emr_on_ecs/node_group/emr_on_ecs_node_group_guide.md中的说明进行操作。