RTC MCP 服务器

用于管理阿里云实时计算 Apache Flink 资源的模型上下文协议 (MCP) 服务器实现。此服务器为 AI 模型与阿里云 Flink 服务交互提供了一个标准化接口。

功能特性

• 创建和管理 Flink 集群
• 创建和管理 Flink SQL 作业
• 部署和控制 Flink 应用程序
• 监控作业状态和指标
• 创建和管理 Savepoint
• 列出和管理部署
• 工作空间和命名空间管理

前提条件

• JDK 17 或更高版本
• Maven 3.6 或更高版本
• 具有 RTC (实时计算) 访问权限的阿里云账号
• 阿里云 Access Key ID 和 Secret

客户端配置

要将此服务器用作 MCP 客户端，请将以下配置添加到您的 MCP 设置文件（例如，cline_mcp_settings.json）：

{
  "mcpServers": {
    "rtc-mcp-server": {
      "command": "java",
      "args": [
        "-Dtransport.mode=stdio",
        "-Dspring.main.web-application-type=none",
        "-Dspring.main.banner-mode=off",
        "-Dlogging.file.name=/path/to/rtc-mcp-server/mcpserver.log",
        "-jar",
        "/path/to/rtc-mcp-server/target/rtc-mcp-server-1.0-SNAPSHOT.jar"
      ],
      "env": {
        "ALIYUN_ACCESS_KEY_ID": "your-access-key-id",
        "ALIYUN_ACCESS_KEY_SECRET": "your-access-key-secret"
      },
      "disabled": false,
      "autoApprove": []
    }
  }
}

将 /path/to/rtc-mcp-server 替换为您的实际服务器路径，并在环境变量中提供您的阿里云凭据。

可用工具

该服务器提供以下 MCP 工具：

1. 作业管理

   • start_job: 启动已部署的 Flink 作业
   • stop_job: 停止正在运行的 Flink 作业
   • list_jobs: 列出部署中的所有作业
   • delete_job: 删除未运行的作业
   • get_job_diagnosis: 获取作业诊断信息

2. 部署管理

   • create_deployment: 创建新的 Flink 部署
   • get_deployment_metrics: 获取部署指标
   • create_savepoint: 为作业创建 Savepoint

3. 变量管理

   • create_variable: 创建新变量
   • update_variable: 更新现有变量
   • delete_variable: 删除变量
   • list_variables: 分页列出变量

4. 工作空间管理

   • create_workspace: 创建新的工作空间
   • get_workspace_info: 获取工作空间信息
   • list_workspaces: 列出所有工作空间

5. Catalog 操作

   • get_catalogs: 获取 Catalog 信息
   • get_deployment_databases: 获取数据库信息
   • get_tables: 获取表信息
   • execute_sql_statement: 执行 SQL 语句

构建和运行

1. 构建项目：

mvn clean package

2. 运行服务器：

java -jar target/rtc-mcp-server-1.0-SNAPSHOT.jar

对于使用 stdio 传输的开发模式：

java -Dtransport.mode=stdio -Dspring.main.web-application-type=none -jar target/rtc-mcp-server-1.0-SNAPSHOT.jar

服务器模式

服务器支持多种传输模式：

• webflux: 使用 Spring WebFlux 的默认模式
• stdio: 用于开发和测试的命令行模式

日志

日志在 application.yml 中配置，具有以下默认设置：

• 根级别：WARN
• 应用程序级别 (com.rtc)：INFO
• 日志文件每天轮换并使用 GZIP 压缩

贡献

1. Fork 仓库
2. 创建一个特性分支
3. 提交您的更改
4. 创建一个 Pull Request

许可证

在 Apache License, Version 2.0（“许可证”）下获得许可； 除非遵守许可证，否则您不得使用此文件。 您可以在以下位置获得许可证副本：

http://www.apache.org/licenses/LICENSE-2.0

除非适用法律要求或书面同意，否则根据“按原样”基础分发的软件 不附带任何形式的明示或暗示的保证或条件。 请参阅许可证，以了解管理权限和 许可证限制的特定语言。