diff --git a/src/server/mcp_server.py b/src/server/mcp_server.py new file mode 100644 index 0000000..72215d9 --- /dev/null +++ b/src/server/mcp_server.py @@ -0,0 +1,142 @@ +""" +MCP 服务器 - jina-reader-agent-v3-270390 + +Agent with 1 external tools +使用 Pydantic AI 和 FastMCP 框架。 +自动生成时间: 2026-02-05T05:44:00.555750 +""" +import json +import os +from typing import Optional + +import httpx +from mcp.server.fastmcp import FastMCP +from pydantic_ai import Agent + +# ==================== 配置 ==================== + +# LiteLLM Gateway 配置 +_BASE_URL = os.getenv('OPENAI_BASE_URL', + os.getenv('LLM_BASE_URL', 'https://litellm.graystone-fb459c5d.southeastasia.azurecontainerapps.io/v1')) +_API_KEY = os.getenv('OPENAI_API_KEY', 'sk') + +os.environ.setdefault('OPENAI_API_KEY', _API_KEY) +os.environ.setdefault('OPENAI_BASE_URL', _BASE_URL) + +# 模型名称(pydantic_ai 需要 openai: 前缀) +def _get_model_name() -> str: + model = os.getenv('MODEL_NAME', os.getenv('LITELLM_MODEL', 'taiji/gpt-4o-mini')) + return model if ':' in model else f'openai:{model}' + +MODEL_NAME = _get_model_name() + +# ==================== MCP 服务器 ==================== + +server = FastMCP('jina-reader-agent-v3-270390') + +# 系统提示词 +SYSTEM_PROMPT = """你是 jina-reader-agent-v3-270390,一个专业的 AI 智能助手。 + +## 角色定位 +Agent with 1 external tools + +## 可用工具 +- jina_reader_v3: 使用 Jina Reader API 爬取网页内容,返回干净的 Markdown 格式 + +## 工作原则 +1. 理解用户意图:仔细分析用户的请求,确保准确理解需求 +2. 选择合适工具:根据需求选择最合适的工具来完成任务 +3. 清晰反馈:以用户友好的方式呈现结果 +4. 错误处理:遇到问题时提供有用的错误信息和建议 + +## 响应格式 +- 对于数据查询:返回结构化的 JSON 数据 +- 对于操作请求:返回操作状态和结果 +- 始终使用中文与用户交流(除非用户使用其他语言)""" + + +def get_agent() -> Agent: + """创建 Agent 实例(每次调用使用最新的 API Key)""" + return Agent(MODEL_NAME, system_prompt=SYSTEM_PROMPT) + + +# ==================== MCP 工具定义 ==================== + +@server.tool() +async def jina_reader_v3(url: str) -> str: + """ + 使用 Jina Reader API 爬取网页内容,返回干净的 Markdown 格式 + + Args: + url: 要爬取的网页URL + + Returns: + JSON 字符串格式的响应 + """ + try: + api_token = os.getenv("TOOL_API_KEY") + if not api_token: + return json.dumps({ + "error": "Missing API key", + "message": "TOOL_API_KEY environment variable is not set" + }, ensure_ascii=False) + + # 将目标URL拼接到API路径中 + api_url = f"https://r.jina.ai/{url}" + + headers = { + "Authorization": f"Bearer {api_token}" + } + + async with httpx.AsyncClient(timeout=60.0) as client: + response = await client.get(api_url, headers=headers) + response.raise_for_status() + + return json.dumps({ + "success": True, + "content": response.text, + "status_code": response.status_code + }, ensure_ascii=False) + + except httpx.HTTPStatusError as e: + return json.dumps({ + "error": "HTTP error", + "message": str(e), + "status_code": e.response.status_code, + "response": e.response.text + }, ensure_ascii=False) + + except httpx.RequestError as e: + return json.dumps({ + "error": "Request error", + "message": str(e) + }, ensure_ascii=False) + + except Exception as e: + return json.dumps({ + "error": "Unexpected error", + "message": str(e) + }, ensure_ascii=False) + + +# ==================== 工具映射(供 API 使用)==================== + +TOOL_MAP = { + 'jina_reader_v3': jina_reader_v3, +} + +TOOL_LIST = [ + { + "name": "jina_reader_v3", + "description": "使用 Jina Reader API 爬取网页内容,返回干净的 Markdown 格式", + "inputSchema": { + "type": "object", + "properties": {"url": {"type": "string", "description": "要爬取的网页URL"}}, + "required": [] + } + }, +] + + +if __name__ == '__main__': + server.run()