Ibook000/crypto_mcp_server

Crypto MCP Server 🚀

加密货币市场数据MCP服务器，提供实时价格、K线数据、资金费率和行业新闻查询功能。采用模块化设计，支持多数据源集成和工具扩展，适用于量化交易分析、市场监控和加密货币研究。

✨ 核心功能

• 实时价格查询：支持单个/批量加密货币价格获取，数据来源于币安交易所
• K线数据分析：提供多种时间周期（1m-1M）的历史K线数据，包含开盘价、最高价、最低价、收盘价和交易量
• 资金费率监控：永续合约资金费率历史数据查询，支持自定义获取数量
• 行业新闻聚合：整合Odaily新闻源，提供今日/昨日加密货币行业动态和重要资讯
• 性能优化：内置请求缓存机制，减少重复API调用，提升响应速度
• 灵活扩展：模块化架构设计，新增数据源或工具仅需实现对应接口

📂 项目结构详解

核心模块详细说明

🚀 crypto_mcp_server.py

• 数据获取层：fetch_crypto_price, fetch_crypto_klines等异步函数，负责从交易所API获取原始数据
• 数据格式化层：format_crypto_data, format_crypto_klines等函数，将原始数据转换为用户友好的文本格式
• 工具注册层：使用@mcp.tool()装饰器注册工具，定义工具名称、参数和功能描述
• 主程序入口：支持标准I/O运行模式，可通过mcp.run(transport='stdio')启动服务

🔧 mcp_client.py

• 连接管理：自动处理与MCP服务器的连接建立和维护
• 工具调用：提供简洁的call()方法，支持位置参数和关键字参数传递
• 响应处理：内置错误处理和数据解析，返回格式化结果
• 批量操作：支持同时调用多个工具，提高处理效率

🚀 快速开始指南

环境要求

• Python 3.8+

安装步骤

git clone https://github.com/Ibook000/crypto_mcp_server.git
cd crypto_mcp_server
python crypto_mcp_server.py

客户端使用示例

from mcp_client import MCPClient

# 初始化客户端
client = MCPClient()

# 查询单个加密货币价格
btc_price = client.call("query_crypto_price", symbol="BTCUSDT")
print(btc_price)

# 批量查询价格
prices = client.call("query_batch_crypto_prices", symbols=["BTCUSDT", "ETHUSDT", "BNBUSDT"])
print(prices)

# 查询K线数据
klines = client.call("query_crypto_klines", symbol="BTCUSDT", interval="1h", limit=24)
print(klines)

# 查询资金费率
funding_rates = client.call("query_funding_rate", symbol="BTCUSDT", limit=7)
print(funding_rates)

# 获取今日新闻
news = client.call("query_crypto_news", length=0)
print(news)

🛠️ 工具参数详解

1. query_crypto_price

获取单个加密货币的实时价格

• 参数：symbol (str) - 交易对符号，如"BTCUSDT"
• 返回：格式化的价格信息字符串
• 示例：query_crypto_price(symbol="BTCUSDT")

2. query_batch_crypto_prices

批量获取多个加密货币的实时价格

• 参数：symbols (list) - 交易对符号列表，如["BTCUSDT", "ETHUSDT"]
• 返回：格式化的批量价格信息字符串
• 示例：query_batch_crypto_prices(symbols=["BTCUSDT", "ETHUSDT"])

3. query_crypto_klines

获取加密货币的历史K线数据

• 参数：
  • symbol (str) - 交易对符号
  • interval (str) - 时间周期，可选值：1m, 3m, 5m, 15m, 30m, 1h, 2h, 4h, 6h, 8h, 12h, 1d, 3d, 1w, 1M
  • limit (int) - 获取数量，1-1000，默认100
• 返回：格式化的K线数据表格
• 示例：query_crypto_klines(symbol="BTCUSDT", interval="1h", limit=24)

4. query_funding_rate

获取永续合约的资金费率历史数据

• 参数：
  • symbol (str) - 永续合约交易对符号
  • limit (int) - 获取数量，1-1000，默认10
• 返回：格式化的资金费率历史数据
• 示例：query_funding_rate(symbol="BTCUSDT", limit=7)

5. query_crypto_news

获取加密货币行业新闻

• 参数：length (int) - 0表示今日新闻，1表示昨日新闻，默认0
• 返回：格式化的新闻摘要列表
• 示例：query_crypto_news(length=0)

📝 详细示例输出

价格查询

交易对: BTCUSDT
价格: 30000.00000000 USDT

批量价格查询

📊 批量价格查询结果：
交易对: BTCUSDT
价格: 30000.00000000 USDT
交易对: ETHUSDT
价格: 1800.00000000 USDT
交易对: BNBUSDT
价格: 300.00000000 USDT

K线数据

🕰️ K线数据列表（时间从旧到新）：
时间                 开盘       最高       最低       收盘       交易量
--------------------------------------------------------------------
2023-07-01 00:00:00  29800.00   30200.00   29700.00   30000.00   1250.50
2023-07-01 01:00:00  30000.00   30500.00   29900.00   30300.00   980.75
2023-07-01 02:00:00  30300.00   30400.00   30000.00   30100.00   750.25

资金费率

资金费率历史数据（时间从旧到新）：
时间                 交易对     资金费率      收取时间
----------------------------------------------------
2023-06-28 08:00:00  BTCUSDT     0.0125%  2023-06-29 08:00:00
2023-06-29 08:00:00  BTCUSDT     0.0150%  2023-06-30 08:00:00
2023-06-30 08:00:00  BTCUSDT     0.0100%  2023-07-01 08:00:00

加密货币新闻

加密货币新闻摘要：
【快讯】标题：比特币突破30000美元关口
简介：比特币价格今日上涨5%，突破30000美元重要阻力位，市场情绪回暖。
发布时间：2023-07-01 10:30:00
源网址：https://www.odaily.news/news/12345

【文章】标题：以太坊合并后生态系统发展分析
摘要：本文详细分析了以太坊合并后三个月的生态系统变化，包括DeFi、NFT和Layer2的发展情况。
发布时间：2023-07-01 09:15:00
源网址：https://www.odaily.news/post/67890

🔧 开发指南

项目架构

本项目采用分层架构设计：

1. 接口层：MCP工具定义和注册
2. 业务逻辑层：数据处理和格式化
3. 数据访问层：API请求和响应处理
4. 基础设施层：配置管理、日志和错误处理

添加新工具步骤

1. 实现数据获取函数：在crypto_mcp_server.py中添加新的异步数据获取函数

async def fetch_new_data(param1, param2):
    # 实现API调用逻辑
    pass

2. 实现格式化函数：创建数据格式化函数，将原始API响应转换为用户友好的格式

def format_new_data(data):
    # 实现数据格式化逻辑
    pass

3. 注册新工具：使用@mcp.tool()装饰器注册新工具

@mcp.tool()
async def query_new_tool(param1, param2):
    """工具描述"""
    data = await fetch_new_data(param1, param2)
    return format_new_data(data)

4. 更新文档：在README.md中添加新工具的参数说明和使用示例

性能优化建议

• 缓存策略：对于频繁访问的静态数据，可增加缓存机制
• 批量请求：尽量使用批量API接口减少请求次数
• 异步处理：保持I/O操作的异步特性，避免阻塞事件循环
• 连接池：使用HTTP连接池复用TCP连接，减少握手开销

⚠️ 故障排除

常见问题及解决方法

1. API请求失败

   • 检查网络连接和防火墙设置
   • 验证API密钥是否正确配置
   • 查看API提供商的状态页面，确认服务是否正常

2. 数据格式错误

   • 检查参数是否符合API要求（如交易对格式、时间周期等）
   • 确认API响应格式是否有变化
   • 查看日志文件获取详细错误信息

3. 服务器启动失败

   • 检查端口是否被占用
   • 验证依赖包是否正确安装
   • 检查配置文件格式是否正确

🤝 贡献指南

欢迎提交Issue和Pull Request来改进本项目。提交代码时请遵循以下规范：

• 代码风格符合PEP 8标准
• 添加必要的单元测试
• 更新相关文档
• 提交信息清晰明了，格式为[类型]: 描述（如[Feature]: 添加ETHGas查询工具）

📄 许可证

本项目采用MIT许可证 - 详情参见LICENSE文件

📞 联系方式

如有问题或建议，请联系：

• GitHub: Ibook000
• Email:

最后更新：2025年7月16日