
RTC MCP Server

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服务交互的场景
工具列表
- Job Management
start_job
: 启动已部署的Flink作业stop_job
: 停止正在运行的Flink作业list_jobs
: 列出部署中的所有作业delete_job
: 删除非运行中的作业-
get_job_diagnosis
: 获取作业诊断信息 -
Deployment Management
create_deployment
: 创建新的Flink部署get_deployment_metrics
: 获取部署指标-
create_savepoint
: 为作业创建保存点 -
Variable Management
create_variable
: 创建新变量update_variable
: 更新现有变量delete_variable
: 删除变量-
list_variables
: 分页列出变量 -
Workspace Management
create_workspace
: 创建工作区get_workspace_info
: 获取工作区信息-
list_workspaces
: 列出所有工作区 -
Catalog Operations
get_catalogs
: 获取目录信息get_deployment_databases
: 获取数据库信息get_tables
: 获取表信息execute_sql_statement
: 执行SQL语句
使用教程
使用依赖
- JDK 17或更高版本
- Maven 3.6或更高版本
- 具有RTC访问权限的阿里云账户
- 阿里云访问密钥ID和密钥
安装教程
- 构建项目:
mvn clean package
- 运行服务器:
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压缩