【大模型系列篇】大模型基建工程:基于 FastAPI 自动构建 SSE MCP 服务器

【大模型系列篇】大模型基建工程:基于 FastAPI 自动构建 SSE MCP 服务器

今天我们将使用FastAPI来构建 MCP 服务器,Anthropic 推出的这个MCP 协议,目的是让 AI 代理和你的应用程序之间的对话变得更顺畅、更清晰。FastAPI 基于 Starlette 和 Uvicorn,采用异步编程模型,可轻松处理高并发请求,尤其适合 MCP 场景下大模型与外部系统的实时交互需求,其性能接近 Node.js 和 Go,在数据库查询、文件操作等 I/O 密集型任务中表现卓越。

开始今天的正题前,我们来回顾下相关的知识内容:

高性能Python Web服务部署架构解析》、《使用Python开发MCP Server及Inspector工具调试》、《构建智能体MCP客户端:完成大模型与MCP服务端能力集成与最小闭环验证

 

FastAPI基础知识

安装依赖

pip install uvicorn, fastapi

FastAPI服务代码示例 

from fastapi import FastAPI app = FastAPI() @app.get("/") async def root(): return {"data": "Hello MCP!"}

uvicorn启动server 

uvicorn server:app --reload

接下来,我们将基于FastAPI来开发MCP服务器

 

FastAPI开发MCP Server

FastAPI-MCP 一个零配置工具,用于自动将FastAPI端点暴露为模型上下文协议(MCP)工具。其特点在于简洁性和高效性,以下是一些主要特点:

  • 直接集成:不需要复杂的设置,直接集成到FastAPI应用中。
  • 自动转换:无需手动编写代码,自动将FastAPI端点转换为MCP工具。
  • 灵活性:支持自定义MCP工具,与自动生成的工具一同使用。
  • 性能:基于Python 3.10+和FastAPI,保证了高性能的API服务。
  • 文档友好:保持了原有的API文档,方便开发者使用和理解。

安装依赖

pip install fastapi-mcp

MCP服务代码示例

from fastapi import FastAPI from fastapi_mcp import add_mcp_server from typing import Any import httpx # 常量 NWS_API_BASE = "https://api.weather.gov" USER_AGENT = "weather-app/1.0" app = FastAPI() mcp_server = add_mcp_server( app, # FastAPI 应用 mount_path="/mcp", # MCP 服务器挂载的位置 name="Weather MCP Server", # MCP 服务器的名字 describe_all_responses=True, # 默认是 False。就像打开一个百宝箱,把所有可能的响应模式都包含在工具描述里,而不只是成功的响应。 describe_full_response_schema=True # 默认是 False。把完整的 JSON 模式包含在工具描述里,而不只是一个对大语言模型友好的响应示例。 ) async def make_nws_request(url: str) -> dict[str, Any] | None: """向 NWS API 发起请求,并进行错误处理。""" headers = { "User-Agent": USER_AGENT, "Accept": "application/geo+json" } async with httpx.AsyncClient() as client: try: response = await client.get(url, headers=headers, timeout=30.0) response.raise_for_status() return response.json() except Exception: return None @mcp_server.tool() async def get_forecast(latitude: float, longitude: float) -> str: """获取地点的天气预报。 参数: latitude: 地点的纬度 longitude: 地点的经度 """ points_url = f"{NWS_API_BASE}/points/{latitude},{longitude}" points_data = await make_nws_request(points_url) if not points_data: return "Unable to fetch forecast data for this location." forecast_url = points_data["properties"]["forecast"] forecast_data = await make_nws_request(forecast_url) if not forecast_data: return "Unable to fetch detailed forecast." periods = forecast_data["properties"]["periods"] forecasts = [] for period in periods[:5]: forecast = f""" {period['name']}: Temperature: {period['temperature']}°{period['temperatureUnit']} Wind: {period['windSpeed']} {period['windDirection']} Forecast: {period['detailedForecast']} """ forecasts.append(forecast) return "\n---\n".join(forecasts)

启动 mcp server

uvicorn server:app --host 0.0.0.0 --port 8001 --reload

 启动 mcp inspector 调试

CLIENT_PORT=8081 SERVER_PORT=8082 npx -y @modelcontextprotocol/inspector

当集成了 MCP 的 FastAPI 应用运行起来后,可以用任何支持 SSE 的 MCP 客户端连接它。我们这里还是使用 mcp inspector 进行调试,通过 SSE 连接 Weather MCP 服务器。

SSE是一种单向通信的模式,所以它需要配合HTTP Post来实现客户端与服务端的双向通信。严格的说,这是一种HTTP Post(客户端->服务端) + HTTP SSE(服务端->客户端)的伪双工通信模式,区别于WebSocket双向通信

 

如果MCP客户端不支持SSE,可以使用mcp-proxy连接MCP服务器。本质上是本地通过stdio连接到mcp-proxy,再由mcp-proxy通过SSE连接到MCP Server上。

mcp-proxy 支持两种模式,stdio to SSE SSE to stdio

安装 mcp-proxy

uv tool install mcp-proxy

配置 claude_desktop_config.json 

{ "mcpServers": { "weather-api-mcp-proxy": { "command": "mcp-proxy", "args": ["http://127.0.0.1:8001/mcp"] } } }

FastAPI-MCP 目前还有很多功能不完善,我们将持续关注进展。在《大模型基建工程:基于 FastAPI 自动构建 SSE MCP 服务器 —— 进阶篇》中我们手搓了一个自动挂载的功能,并基于现有fastapi base_url 将 api 挂载至 mcp_server。

大模型基建工程总结

FastAPI 构建 MCP 服务器的核心价值在于:通过类型安全的异步接口,将企业现有能力快速转化为大模型可调用的标准化服务。这种架构既保留了 FastAPI 的高效开发体验,又通过 MCP 协议实现了与前沿 AI 技术的无缝对接,同时结合 Docker 和 Kubernetes 实现弹性伸缩部署,可以快速应对大模型调用量的突发增长,是构建下一代智能系统的理想选择。

Read more

【2026最新】docker desktop for windows下载安装保姆级教程(附最新版安装包)

【2026最新】docker desktop for windows下载安装保姆级教程(附最新版安装包)

Docker Desktop for Windows(简称 Docker Desktop)是 Docker 公司在 Windows 上推出的桌面级图形安装包,把原本只能在 Linux 上跑的 Docker Engine、Docker Compose、Kubernetes 等一堆组件打包成一键安装程序。 Docker Desktop 的核心功能分为 3 块: 1. 单机容器生命周期管理,镜像、容器、网络、数据卷点点鼠标就能增删改; 2. Docker Compose 集成,写好 yaml 一键起整个微服务栈; 3. 自带 Kubernetes,勾选即可启动三节点最小 K8s,kubectl 已经配好路径,本地就能验证 Deployment、Service、ConfigMap

By Ne0inhk
Flutter 三方库 build_cli_annotations 的鸿蒙化适配指南 - 注解驱动的参数解析、自动化命令生成与高效开发工具链构建实战

Flutter 三方库 build_cli_annotations 的鸿蒙化适配指南 - 注解驱动的参数解析、自动化命令生成与高效开发工具链构建实战

欢迎加入开源鸿蒙跨平台社区:https://openharmonycrossplatform.ZEEKLOG.net Flutter 三方库 build_cli_annotations 的鸿蒙化适配指南 - 注解驱动的参数解析、自动化命令生成与高效开发工具链构建实战 前言 随着 Flutter for OpenHarmony 生态的日益庞大,开发者面临的不仅仅是 UI 适配,还有日益繁琐的项目管理和自动化脚本开发。如何快速编写一个高性能、强类型的命令行工具(CLI),用来自动化执行鸿蒙环境检测、包管理或是代码分发? 传统的 args 库虽然强大,但在处理复杂的多级子命令和参数校验时,代码会迅速变得难以维护。 build_cli_annotations 配合 build_cli 库,为我们提供了一种“代码即文档”的优雅方案。通过在 Dart 类上添加简单的注解,即可自动生成健壮的参数解析逻辑。本文将详细讲解这一技术在鸿蒙开发辅助脚本中的实战落地,助力开发者打造极致的自动化工具链。

By Ne0inhk
Flutter 组件 hydrated_mobx 的适配 鸿蒙Harmony 实战 - 驾驭自动化状态持久化、实现鸿蒙端 UI 状态在重启与多任务切换时的无缝恢复方案

Flutter 组件 hydrated_mobx 的适配 鸿蒙Harmony 实战 - 驾驭自动化状态持久化、实现鸿蒙端 UI 状态在重启与多任务切换时的无缝恢复方案

欢迎加入开源鸿蒙跨平台社区:https://openharmonycrossplatform.ZEEKLOG.net Flutter 组件 hydrated_mobx 的适配 鸿蒙Harmony 实战 - 驾驭自动化状态持久化、实现鸿蒙端 UI 状态在重启与多任务切换时的无缝恢复方案 前言 在鸿蒙(OpenHarmony)生态的深度体验中,用户对“断点续作”有着天然的期待。想象一下,用户正在你的鸿蒙平板 App 上填写一份复杂的表单,或者正在调整一个精密的编辑器参数,此时突然接到了一个紧急的鸿蒙系统推送流转,导致 App 被切入后台甚至因为内存压力被系统回收。 当用户再次点击图标回到 App 时,看到的是冷冰冰的初始化界面,还是瞬间恢复到上一次操作的完美现场? hydrated_mobx 为 Flutter 开发者提供了一套近乎魔法的状态持久化方案。它是对经典 MobX 的强力增强,通过简单的注解或扩展,就能让你的 Store 自动具备“

By Ne0inhk
Apache IoTDB(15):IoTDB查询写回(INTO子句)深度解析——从语法到实战的ETL全链路指南

Apache IoTDB(15):IoTDB查询写回(INTO子句)深度解析——从语法到实战的ETL全链路指南

引言 在工业物联网场景中,时序数据的存储与处理常面临“数据孤岛”困境——生产设备产生的原始数据需经过清洗、聚合、转换等多步处理,才能转化为可分析的业务指标。Apache IoTDB的查询写回(INTO子句)正是破解这一痛点的“数据炼金术”。通过SELECT INTO语句,能将查询结果直接写入新序列,实现“查询-转换-存储”的闭环,相当于在数据库内部构建轻量级ETL管道。 Apache IoTDB 时序数据库【系列篇章】: No.文章地址(点击进入)1Apache IoTDB(1):时序数据库介绍与单机版安装部署指南2Apache IoTDB(2):时序数据库 IoTDB 集群安装部署的技术优势与适用场景分析3Apache IoTDB(3):时序数据库 IoTDB Docker部署从单机到集群的全场景部署与实践指南4Apache IoTDB(4):深度解析时序数据库 IoTDB 在Kubernetes 集群中的部署与实践指南5Apache IoTDB(5)

By Ne0inhk