RTC MCP Server

RTC MCP Server

site icon
2025.03.19 1
Flink管理实时计算作业监控资源管理开发效率数据库
RTC MCP Server 是一个用于管理阿里云实时计算(Apache Flink)资源的模型上下文协议(MCP)服务器实现。该服务器为AI模型提供了一个标准化的接口,用于与阿里云Flink服务进行交互。其核心功能包括Flink集群和SQL作业的管理、应用部署与控制、作业状态和指标监控、保存点管理以及工作区和命名空间管理等。适用于需要高效管理和监控Flink资源的场景,特别是那些希望通过AI模型自动化管理Flink作业的开发者和团队。
View on GitHub

Overview

基本能力

产品定位

RTC MCP Server 是一个专为阿里云实时计算(Apache Flink)设计的MCP服务器,旨在通过标准化接口简化Flink资源的管理和监控。

核心功能

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

适用场景

  • 需要自动化管理Flink作业的开发环境
  • 大规模Flink作业的监控和管理
  • 通过AI模型与Flink服务交互的场景

工具列表

  1. Job Management
  2. start_job: 启动已部署的Flink作业
  3. stop_job: 停止正在运行的Flink作业
  4. list_jobs: 列出部署中的所有作业
  5. delete_job: 删除非运行中的作业
  6. get_job_diagnosis: 获取作业诊断信息

  7. Deployment Management

  8. create_deployment: 创建新的Flink部署
  9. get_deployment_metrics: 获取部署指标
  10. create_savepoint: 为作业创建保存点

  11. Variable Management

  12. create_variable: 创建新变量
  13. update_variable: 更新现有变量
  14. delete_variable: 删除变量
  15. list_variables: 分页列出变量

  16. Workspace Management

  17. create_workspace: 创建工作区
  18. get_workspace_info: 获取工作区信息
  19. list_workspaces: 列出所有工作区

  20. Catalog Operations

  21. get_catalogs: 获取目录信息
  22. get_deployment_databases: 获取数据库信息
  23. get_tables: 获取表信息
  24. execute_sql_statement: 执行SQL语句

使用教程

使用依赖

  • JDK 17或更高版本
  • Maven 3.6或更高版本
  • 具有RTC访问权限的阿里云账户
  • 阿里云访问密钥ID和密钥

安装教程

  1. 构建项目:
mvn clean package
  1. 运行服务器:
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

调试方式

  • 日志配置在application.yml中,默认设置:
  • 根级别: WARN
  • 应用级别(com.rtc): INFO
  • 日志文件每日轮换并使用GZIP压缩

许可证

该项目遵循 Apache License 2.0 开源许可条款。