完美 MCP 服务器
Prefect的模型上下文协议 (MCP) 服务器实现,允许 AI 助手通过自然语言与 Prefect 进行交互。
特征
该 MCP 服务器提供对以下 Prefect API 的访问:
流程管理:列出、获取和删除流程
流程运行管理:创建、监控和控制流程运行
部署管理:管理部署及其时间表
任务运行管理:监视和控制任务运行
工作队列管理:创建和管理工作队列
区块管理:访问区块类型和文档
变量管理:创建和管理变量
工作区管理:获取有关工作区的信息
Related MCP server: n8n MCP Server
配置
设置以下环境变量:
export PREFECT_API_URL="http://localhost:4200/api" # URL of your Prefect API
export PREFECT_API_KEY="your_api_key" # Your Prefect API key (if using Prefect Cloud)
用法
运行 MCP 服务器,并进行以下操作:
docker compose up
示例输入
连接后,AI助手可以帮助用户使用自然语言与Prefect进行交互。示例:
“显示我的所有流程”
“列出昨天所有失败的流程运行”
“触发‘数据处理’部署”
“暂停‘每日报告’部署计划”
“我上次 ETL 流程运行的状态如何?”
发展
一些端点尚未实现
添加新功能
要向现有 API 添加新功能:
将该函数添加到
src/mcp_prefect中的相应模块将函数添加到模块中的
get_all_functions()列表中
要添加新的 API 类型:
在
enums.py中将新类型添加到APIType在
src/prefect/中创建一个新模块更新
main.py以包含新的 API 类型
使用示例:
{
"mcpServers": {
"mcp-prefect": {
"command": "mcp-prefect",
"args": [
"--transport", "sse"
],
"env": {
"PYTHONPATH": "/path/to/your/project/directory"
},
"cwd": "/path/to/your/project/directory"
}
}
}
This server cannot be installed