mcpField
B
byted-volcengine-flink

byted-volcengine-flink

github.com/bytedance数据与数据库47746 次安装今天更新
代码仓库

关于 byted-volcengine-flink

这是火山引擎 Flink 的聚合技能，根据需求将开发部署、只读诊断、资源分析和 SRE 运维任务分发到对应子技能。它面向使用 Flink 的开发与运维人员，并要求变更操作先确认风险。

主要功能

  1. 01按意图路由到 Flink 子技能
  2. 02支持 SQL 开发与部署任务
  3. 03区分只读诊断和资源分析
  4. 04变更操作前确认风险

适用场景

  1. 01创建、调试或部署 Flink SQL
  2. 02只读排查 Flink 任务问题
  3. 03分析 OOM、Checkpoint 或性能故障
  4. 04执行启停、扩缩容或配置修改

MCP 相关

使用前需完成 flink-mcp 配置，并在 MCP 客户端配置中注册该服务；文档还说明了相关环境变量和手动启动方式。

安装

复制下面的命令，在终端中运行。

$npx skills add https://github.com/bytedance/agentkit-samples --skill byted-volcengine-flink

安装后在 Claude Code 中输入/byted-volcengine-flink确认已加载。

包含的文件

除 SKILL.md 外，安装时一起下载的参考资料和脚本。

flink-dev.md
flink-diagnosis.md
flink-resource.md
flink-sre.md
LICENSE

详细介绍

来自项目 README

Byted Volcengine Flink

火山引擎 Flink 聚合技能入口，用于统一处理 Flink 相关需求，并按意图转发到对应子技能文档。

前置环境

在安装并使用本技能前，需要先完成 flink-mcp 前置准备。

1) 安装并验证 mcporter

flink-dev.md、flink-resource.md、flink-sre.md 中的运维/诊断指令依赖 mcporter。

可按你的 Python 环境选择任一方式安装：

npm install -g mcporter

安装后验证：

mcporter --help
2) 配置必需环境变量

flink-mcp 启动依赖以下环境变量（缺一不可）：

  • VOLCENGINE_ACCESS_KEY
  • VOLCENGINE_SECRET_KEY
  • VOLCENGINE_REGION
  • VOLCENGINE_PROJECT_NAME

示例：

export VOLCENGINE_ACCESS_KEY="your-access-key"
export VOLCENGINE_SECRET_KEY="your-secret-key"
export VOLCENGINE_REGION="cn-beijing"
export VOLCENGINE_PROJECT_NAME="your-flink-project"
3) 在本地 MCP 配置文件中注册 flink-mcp（推荐）

将 flink-mcp 加入本地 MCP Client 使用的配置文件（通常为 mcp.json 或等效配置文件）。

说明：MCP Client 会根据这段配置拉起 flink-mcp，因此这是默认主路径。

先确保本地已安装 uv / uvx，然后写入如下配置：

{
  "mcpServers": {
    "mcp-server-flink": {
      "command": "uvx",
      "args": [
        "--from",
        "git+https://github.com/volcengine/mcp-server#subdirectory=server/mcp_server_flink",
        "mcp-server-flink",
        "-t",
        "streamable-http"
      ],
      "env": {
        "VOLCENGINE_ACCESS_KEY": "${VOLCENGINE_ACCESS_KEY}",
        "VOLCENGINE_SECRET_KEY": "${VOLCENGINE_SECRET_KEY}",
        "VOLCENGINE_REGION": "${VOLCENGINE_REGION}",
        "VOLCENGINE_PROJECT_NAME": "${VOLCENGINE_PROJECT_NAME}",
        "UV_INDEX_URL": "https://mirrors.ivolces.com/pypi/simple/"
      }
    }
  }
}
4) 可选：手动启动 flink-mcp（仅用于联调/排障）

当需要独立验证服务是否可启动时，可在终端手动执行：

uvx --from git+https://github.com/volcengine/mcp-server#subdirectory=server/mcp_server_flink mcp-server-flink -t streamable-http

子技能引用与路由

根据用户需求，将任务路由到以下子技能：

  • 开发/部署 Flink SQL：flink-dev.md
  • 只读诊断（禁止变更操作）：flink-diagnosis.md
  • 资源与故障分析：flink-resource.md
  • SRE 运维变更（启停/重启/扩缩容/参数修改）：flink-sre.md
路由规则
  1. 用户表达“创建 SQL / 开发 SQL / 部署 SQL / 调试 SQL”时，优先使用 flink-dev.md。
  2. 用户明确要求“只读排查、不做任何变更”时，必须使用 flink-diagnosis.md。
  3. 用户询问故障根因、OOM、Checkpoint、性能问题、连接问题时，优先使用 flink-resource.md。
  4. 用户要求执行运维动作（启动、停止、重启、扩容、缩容、改配置）时，必须使用 flink-sre.md，且先做风险确认。

执行原则

  • 在信息不足时，先补齐关键参数：项目名、任务名、时间范围、目标动作。
  • 任何变更类操作（尤其在 flink-sre.md 中）都必须先让用户确认风险。
  • 当用户只需要排查时，坚持只读工具链，不触发启动/停止/部署等动作。

评论

支持 Markdown