MCP 服务接入

架构概览

核心能力

两套 OpenAPI 覆盖以下能力域，勾选对应 API 即可封装为 MCP 工具。

• 官方推荐的故障诊断场景包（本文示例均基于此）由其中的诊断类 API 组合而成，见「创建 MCP Server」。作业运维、数据查询等场景包按相同方法勾选对应 API 即可，见「API 选择建议」。

• 除上述能力域外，智能助手对话（ChatAiAgent）、智能巡检（ListPatrolReports、TriggerPatrol 等 5 个 API）与 AI 服务管理（GetFlinkAiService 等，售卖面 foasconsole）相关 API 也已开放，可按相同方式勾选封装，见「AI 智能运维」。

作业诊断

适用场景：作业运行失败、频繁 Failover 与重启、启动失败、性能劣化等问题的根因定位。

示例提问：我有一个 Flink 作业今天上午开始频繁重启，帮我定位一下原因。

诊断链路如下。

诊断结论包含以下三部分。

• 根因分类：反压、资源不足、代码异常、外部依赖等，取自 GetJobDiagnosis 的诊断项。

• 证据引用：诊断项描述、启动日志关键行或事件时间线，需可回溯到上述工具的返回内容。

• 处置建议：优先采用诊断项自带的修复建议，并结合 ListSavepoints 确认恢复点与检查点健康度。

若证据不足，可要求模型补充调用 ListSavepoints 或 ListAutopilotTuningHistories，还原完整上下文。

AI 智能运维

实时计算 Flink 版的 AI 智能助手与智能巡检能力已通过 OpenAPI 开放，相关 API 可按相同方式勾选封装为 MCP 工具，适用于将 AI 运维能力集成进企业自建 Agent 与流程。两项能力在控制台亦有对应入口，无需接入即可直接使用。

管控面 ververica 提供智能助手对话与智能巡检全套 API。

AI 能力依赖 Flink AI 服务，其开通状态、关闭保护与免费额度用量通过 OpenAPI（售卖面 foasconsole）开放，可勾选封装为 MCP 工具，便于在企业自有流程中统一查询与管理。

• 两条 AI 使用路径互补：MCP 封装适合将 AI 运维能力整合进企业自建 Agent 与可观测体系；控制台入口融合平台专家经验与内置 Skill，直接可用。

• 智能助手与智能巡检按 Token 用量计费，正式商用前提供免费体验额度，额度与计费详情以控制台 AI 服务页面为准。

推荐 API 清单

以下为官方首推的故障诊断场景包：9 个 API 均为只读接口，覆盖「定位作业 → 实例状态 → 根因诊断 → 事件还原」完整诊断链路。

MCP 指令模板

MCP 指令用于引导大模型按既定工作流调用工具，需客户端支持 Instructions 字段。故障诊断场景包的指令模板如下，创建 MCP Server 时粘贴至 MCP 指令 框。

你是实时计算 Flink 版作业诊断助手。诊断作业问题时按以下流程：
1) 用 ListDeployments 或 GetDeploymentsByName 定位目标作业；
2) 用 ListJobs 获取实例列表，确认失败实例与时间点；
3) 对失败实例调用 GetJobDiagnosis，读取异常诊断项（反压、资源不足、代码异常、网络等）；
4) 若作业启动失败，调用 GetLatestJobStartLog 查看启动日志中的异常堆栈；
5) 结合 GetEvents 的事件时间线还原 failover 过程，必要时参考 ListAutopilotTuningHistories 判断是否受自动调优影响；
6) 输出结论：根因分类 + 证据（引用诊断项或日志关键行）+ 处置建议。
本 MCP 仅提供只读能力，不执行启停等变更操作。

创建步骤

1. 登录 OpenAPI MCP 服务控制台，在左侧导航栏单击自定义 > 创建。

2. 参照下表完成配置。

3. 单击创建并确认风险提示。

4. 创建完成后，页面显示 Streamable HTTP Endpoint 与 SSE Endpoint，复制并保存。服务地址格式如下。

https://openapi-mcp.cn-hangzhou.aliyuncs.com/accounts/<账号ID>/custom/<MCP服务名称>/id/<服务ID>/mcp

OAuth 直连

客户端支持直接添加远程 MCP 服务（如 Qoder）时，在客户端的 MCP 设置中添加远程服务，地址填入 Streamable HTTP Endpoint。支持显式指定传输类型的客户端选择 streamable-http 或 sse；Qoder IDE 按 URL 自动识别传输类型，无需单独指定。

{
  "mcpServers": {
    "flink_diagnosis": {
      "type": "streamable-http",
      "url": "<你的 Streamable HTTP Endpoint>"
    }
  }
}

客户端仅支持 STDIO（如 Cursor、通义灵码）时，通过 mcp-remote-alibaba-cloud 桥接。

{
  "mcpServers": {
    "flink_diagnosis": {
      "command": "npx",
      "args": [
        "mcp-remote-alibaba-cloud",
        "<你的 Streamable HTTP Endpoint>"
      ]
    }
  }
}

Cursor 请粘贴至 ~/.cursor/mcp.json 或项目根目录 .cursor/mcp.json；通义灵码请在插件 MCP 工具页面按 STDIO 类型添加。

首次连接时弹出浏览器授权页，使用 MCP Server 所属阿里云账号下的 RAM 用户登录并确认授权。系统会校验发起授权的用户与 MCP Server 属于同一主账号，校验通过后客户端才能列出并调用工具。

静态凭证

通过 alibabacloud.mcp-proxy 本地代理，使用 RAM 用户 AK 接入远程 MCP Server。先执行预检查，确认代理与权限就绪。

uvx alibabacloud.mcp-proxy@latest --server-url <MCP 连接地址> pre-check

若本地已完成阿里云 CLI 登录（aliyun configure），代理会自动复用 CLI 凭据，可省略环境变量配置。

在客户端中按 STDIO 类型添加 MCP 服务，配置项如下。