MCP 服务器

MCPEngine

MCPEngine 是模型上下文协议 (MCP) 的客户端、服务器和代理实现，专门面向企业和实际的远程 MCP 应用。

featureform

开发者工具

访问服务器

README

MCPEngine

模型上下文协议 (MCP) 的生产级实现

概述

MCPEngine 是模型上下文协议 (MCP) 的生产级、HTTP 优先实现。它提供了一个安全、可扩展且现代化的框架，用于通过 MCP 向大型语言模型 (LLM) 公开数据、工具和提示。

我们相信 MCP 可以成为 "LLM 的 REST"，使任何应用程序（Slack、Gmail、GitHub 等）都可以公开一个标准化的端点，供 LLM 访问，而无需自定义编码的集成。MCPEngine 是我们为使 MCP 足够强大以满足现代云原生用例而做出的贡献。

主要特性

内置 OAuth，支持 Okta、Keycloak、Google SSO 等。
HTTP 优先设计（SSE 而不仅仅是 stdio）
基于范围的授权，用于工具、资源和提示
通过本地代理无缝桥接 LLM 主机（如 Claude Desktop）
与 FastMCP 和官方 MCP SDK 完全向后兼容

架构

MCPEngine 使用基于代理的架构与 LLM 主机（如 Claude Desktop）集成：

┌───────────────┐     stdio     ┌─────────────────┐     HTTP/SSE     ┌───────────────┐
│  Claude Host  ├───────────────►  MCPProxy Local ├──────────────────► MCPEngine     │
│               │               │                 │                   │ Server        │
│               ◄───────────────┤ (本地运行) ◄──────────────────┬┤ (远程)      │
└───────────────┘               └─────────────────┘      OAuth 2.1   │└───────────────┘
                                                                     │
                                                        ┌────────────┴───────────┐
                                                        │ 身份提供商            │
                                                        │ (Okta, Keycloak, 等) │
                                                        └────────────────────────┘

此架构提供以下几个优点：

无缝集成 - Claude 看到一个本地的基于 stdio 的进程
安全性 - 代理处理 OAuth 身份验证流程
可扩展性 - MCPEngine 服务器可以在任何地方运行（云、本地）
关注点分离 - 身份验证与您的业务逻辑独立处理

安装

uv add "mcpengine[cli]"
# 或
pip install "mcpengine[cli]"

安装完成后，您可以运行 CLI 工具：

mcpengine --help

快速入门

创建服务器

# server.py
from mcpengine import MCPEngine

mcp = MCPEngine("Demo")


@mcp.tool()
def add(a: int, b: int) -> int:
    return a + b


@mcp.resource("greeting://{name}")
def get_greeting(name: str) -> str:
    return f"Hello, {name}!"

Claude Desktop 集成

如果您的服务器位于 http://localhost:8000，您可以在本地启动代理：

mcpengine proxy http://localhost:8000/sse

Claude Desktop 看到一个本地 stdio 服务器，而代理会自动处理任何必要的 OAuth 或 SSE 流量。

核心概念

身份验证和授权

启用 OAuth 和范围：

from mcpengine import MCPEngine, Context

mcp = MCPEngine(
    "SecureDemo",
    authentication_enabled=True,
    issuer_url="https://your-idp.example.com/realms/some-realm",
)


@mcp.auth(scopes=["calc:read"])
@mcp.tool()
def add(a: int, b: int, ctx: Context) -> int:
    ctx.info(f"User {ctx.user_id} with roles {ctx.roles} called add.")
    return a + b

任何调用 add 的尝试都需要用户具有 calc:read 范围。如果没有，服务器将返回 401 Unauthorized，如果通过代理使用，则会提示登录流程。

资源

@mcp.resource("uri"): 为 LLM 提供只读上下文，例如 GET 端点。

from mcpengine import MCPEngine

mcp = MCPEngine("Demo")


@mcp.resource("config://app")
def get_config() -> str:
    return "Configuration Data"

工具

@mcp.tool(): LLM 可调用的函数。它们可以具有副作用或执行计算。

from mcpengine import MCPEngine

mcp = MCPEngine("Demo")


@mcp.tool()
def send_email(to: str, body: str):
    return "Email Sent!"

提示

@mcp.prompt(): 可重用的对话模板。

from mcpengine import MCPEngine

mcp = MCPEngine("Demo")


@mcp.prompt()
def debug_prompt(error_msg: str):
    return f"Debug: {error_msg}"

图像

将图像作为一流数据返回：

from mcpengine import MCPEngine, Image

mcp = MCPEngine("Demo")


@mcp.tool()
def thumbnail(path: str) -> Image:
    # ... 省略函数体
    pass

上下文

每个请求都有一个上下文：

ctx.user_id: 经过身份验证的用户 ID
ctx.user_name: 经过身份验证的用户名
ctx.roles: 用户范围/角色
ctx.info(...): 日志记录
ctx.read_resource(...): 访问其他资源

示例实现

SQLite 浏览器

import sqlite3
from mcpengine import MCPEngine, Context

mcp = MCPEngine(
    "SQLiteExplorer",
    authentication_enabled=True,
    issuer_url="https://your-idp.example.com/realms/some-realm",
)


@mcp.auth(scopes=["database:read"])
@mcp.tool()
def query_db(sql: str, ctx: Context) -> str:
    conn = sqlite3.connect("data.db")
    try:
        rows = conn.execute(sql).fetchall()
        ctx.info(f"User {ctx.user.id} executed query: {sql}")
        return str(rows)
    except Exception as e:
        return f"Error: {str(e)}"

Echo 服务器

from mcpengine import MCPEngine

mcp = MCPEngine("Demo")


@mcp.resource("echo://{msg}")
def echo_resource(msg: str):
    return f"Resource echo: {msg}"


@mcp.tool()
def echo_tool(msg: str):
    return f"Tool echo: {msg}"

Smack - 消息存储示例

Smack 是一个使用 PostgreSQL 存储的简单消息服务示例，演示了 MCPEngine 在 OAuth 2.1 身份验证方面的功能。

快速开始

使用 Docker Compose 启动服务：

git clone https://github.com/featureform/mcp-engine.git
cd mcp-engine/examples/servers/smack
docker-compose up --build

使用 Claude Desktop

配置 Claude Desktop 以使用 Smack：

手动：

touch ~/Library/Application\ Support/Claude/claude_desktop_config.json

添加到文件：

{
  "mcpServers": {
    "smack_mcp_server": {
      "command": "bash",
      "args": [
        "docker attach mcpengine_proxy || docker run --rm -i --net=host --name mcpengine_proxy featureformcom/mcpengine-proxy -host=http://localhost:8000 -debug -client_id=optional -client_secret=optional",
      ]
    }
  }
}