MCP 服务编排器
专为模型上下文协议（MCP）服务器设计的智能路由编排器，用于在GCP BigQuery（车辆数据）和AWS S3表（按州划分的税收数据）之间路由查询。
特点
- 🎯（目标、瞄准） 智能查询路由自动将查询路由到相应的数据源
- 🔗（链接符号，无实际翻译意义，可保持原样或根据上下文替换为具体描述，如“这是一个链接”） 多服务器支持连接到GCP BigQuery和AWS S3表的MCP服务器
- 📊（表格） 置信度评分为路由决策提供置信度评分
- 🚀 火箭或快速前进的象征（无实际文字对应，仅表达意象） 易于集成用于处理查询的简单API
- ⚛️（这个符号在中文中通常没有直接对应的翻译，它是一个化学元素符号“Fe”（铁）的变体或装饰形式，但在中文语境下，我们通常直接使用“铁”或“Fe”来表示这个元素。如果仅从符号本身来看，它可能被理解为一种特殊的标记或符号，没有具体的中文含义。） React 前端用户友好的网页界面，支持自然语言查询
快速入门
开发环境
- 安装Python依赖项：
pip install -e ".[dev]"
pip install -r backend/requirements.txt- 安装React依赖项：
cd frontend
npm install
cd ..- 启动开发服务器：
./start-dev.sh- 访问该应用程序：
- 前端：http://localhost:3000 - 后端API：http://localhost:8000
Python API 使用
import asyncio
from mcp_orchestrator import MCPOrchestrator
async def main():
orchestrator = MCPOrchestrator()
# Configure server commands
gcp_command = ["python", "-m", "mcp_bigquery_server"]
aws_command = ["python", "-m", "mcp_s3tables_server"]
# Connect to servers
await orchestrator.connect(gcp_command, aws_command)
# Process query
result = await orchestrator.process_query(
"What is the average range of electric vehicles?"
)
print(result)
asyncio.run(main())建筑
┌─────────────────┐ ┌─────────────────┐ ┌─────────────────┐
│ React Frontend│ │ FastAPI Backend│ │ MCP Orchestrator│
│ │ │ │ │ │
│ - Query Input │───▶│ - REST API │───▶│ - Query Routing │
│ - Results UI │◀───│ - CORS Support │◀───│ - Server Mgmt │
│ - Examples │ │ - Error Handling│ │ - Confidence │
└─────────────────┘ └─────────────────┘ └─────────────────┘
│
┌────────┴────────┐
▼ ▼
┌─────────────────┐ ┌─────────────────┐
│ GCP BigQuery │ │ AWS S3 Tables │
│ (EV Data) │ │ (Tax Data) │
└─────────────────┘ └─────────────────┘配置
为服务器配置设置环境变量：
export GCP_MCP_COMMAND="python -m mcp_bigquery_server"
export AWS_MCP_COMMAND="python -m mcp_s3tables_server"
export GOOGLE_APPLICATION_CREDENTIALS="/path/to/credentials.json"
export GCP_PROJECT_ID="your-project-id"
export AWS_ACCESS_KEY_ID="your-access-key"
export AWS_SECRET_ACCESS_KEY="your-secret-key"
export AWS_REGION="us-east-1"路由逻辑
协调器使用基于关键字的分析来路由查询：
- 电动汽车数据（BigQuery）包含“ev”、“电动汽车”、“充电”、“电池”、“特斯拉”等关键词的查询
- 税务数据（S3 表格）包含“税收”、“州”、“收入”等关键词以及州名的查询
发展
# Install development dependencies
pip install -e ".[dev]"
# Run tests
pytest
# Format code
black src/ tests/
# Lint code
flake8 src/ tests/
# Type check
mypy src/项目结构
mcp-aws-gcp-orchestrator/
├── src/
│ └── mcp_orchestrator/
│ ├── __init__.py
│ ├── orchestrator.py
│ └── config.py
├── tests/
│ └── test_orchestrator.py
├── examples/
│ └── basic_usage.py
├── docs/
├── pyproject.toml
├── requirements.txt
├── requirements-dev.txt
├── .gitignore
└── README.md许可证
MIT 许可证 - 详情请参阅 LICENSE 文件
贡献；助力
欢迎贡献！请先阅读 CONTRIBUTING.md 文件。