🚀 Python 智能量化交易分析工具 v1.2.0

⚠️ 重要声明

关于OKX交易所支持变更

由于OKX交易所存在恶意平掉用户仓位的不当行为，严重损害了用户利益和交易公平性，本项目自即日起不再支持OKX交易所的新功能开发。

• ✅ 保留现有代码：已有的OKX相关代码将继续保留，确保现有用户的使用不受影响
• ❌ 停止新功能开发：不再为OKX交易所开发新功能或进行适配优化
• 🎯 专注币安适配：后续所有新功能将专注于Binance交易所的支持和优化

我们建议用户迁移至更加可靠和公平的Binance交易所。

---

基于Python的智能量化交易分析工具 v1.2.0，完整支持Binance期货交易所，集成Kronos AI预测模型、技术分析和机器学习算法，专为加密货币市场设计的交易决策系统。

🆕 v1.2.0 更新内容

• ✅ 完整适配Binance期货API - 全面支持币安期货交易所

✨ 核心特性

• 🧠 Kronos AI 预测 - 基于 Transformer 的金融预测模型
• 📊 多维度分析 - 技术分析 + 机器学习 + AI 预测
• 🔄 实时监控 - 负费率、异常波动、持仓量监控、Tradingview强势币推送
• 📱 智能通知 - 飞书、企业微信多渠道推送
• ⚡ 高性能架构 - FastAPI + 异步处理
• 🎯 策略回测 - 完整的策略验证和优化

🚀 快速开始

📋 环境要求

• Python 3.11+
• MySQL 8.0+
• 4GB+ 内存 (推荐 16GB)

🔧 安装配置

1. 克隆项目

git clone https://github.com/ChinaWallace/transaction_push.git
cd transaction_push

2. 安装依赖

# 1. 升级pip
python -m pip install --upgrade pip

# 2. 安装TA-Lib技术指标库
# Windows (推荐使用预编译版本):
pip install --find-links https://github.com/cgohlke/talib-build/releases/download/v0.4.28/ TA-Lib

# Linux/Ubuntu:
sudo apt-get install libta-lib-dev && pip install TA-Lib

# macOS:
brew install ta-lib && pip install TA-Lib

# 3. 安装其他Python依赖
pip install -r requirements.txt

# 4. 下载Kronos AI模型
python scripts/download_kronos_models.py

3. 配置环境变量

# 复制配置模板
cp .env.example .env

# 编辑配置文件
# 必须配置: 交易所 API、数据库连接、通知 Webhook

4. 启动服务

python main.py

🎛️ 核心配置

# 🔑 交易所API配置 (选择一个)
# 币安期货交易所 (推荐 - v1.2.0完整适配)
BINANCE_API_KEY=your_binance_api_key
BINANCE_SECRET_KEY=your_binance_secret_key
BINANCE_BASE_URL=https://fapi.binance.com
EXCHANGE_PROVIDER=binance

# 或者OKX交易所 (不推荐，仅保留兼容性)
# OKX_API_KEY=your_okx_api_key
# OKX_SECRET_KEY=your_okx_secret_key  
# OKX_PASSPHRASE=your_okx_passphrase
# EXCHANGE_PROVIDER=okx

# 💾 数据库配置
DATABASE_URL=mysql+pymysql://root:password@localhost:3306/trading_db

# 📢 通知配置（至少选择一个）
FEISHU_WEBHOOK_URL=https://open.feishu.cn/open-apis/bot/v2/hook/your_webhook_key
# 或
WECHAT_WEBHOOK_URL=https://qyapi.weixin.qq.com/cgi-bin/webhook/send?key=your_key

# 🤖 Kronos AI配置
KRONOS_CONFIG__ENABLE_KRONOS_PREDICTION=true
KRONOS_CONFIG__USE_GPU=false

# 📊 监控币种配置
MONITORED_SYMBOLS=["BTC-USDT-SWAP","ETH-USDT-SWAP","SOL-USDT-SWAP"]

🗄️ 数据库初始化

# 1. 确保MySQL服务运行
# Windows: net start mysql
# Linux: sudo systemctl start mysql

# 2. 创建数据库（如果不存在）
mysql -u root -p -e "CREATE DATABASE IF NOT EXISTS trading_db CHARACTER SET utf8mb4 COLLATE utf8mb4_unicode_ci;"

# 3. 初始化数据库表结构
python scripts/init_db.py

# 4. 验证数据库连接
python -c "from app.core.database import db_manager; print('✅ 数据库连接成功' if db_manager.health_check() else '❌ 数据库连接失败')"

🔧 数据库配置说明

# 标准MySQL配置
DATABASE_URL=mysql+pymysql://用户名:密码@localhost:3306/trading_db

# 示例配置
DATABASE_URL=mysql+pymysql://root:your_password@localhost:3306/trading_db

# 如果使用默认端口和本地连接
DATABASE_URL=mysql+pymysql://root:password@127.0.0.1:3306/trading_db

⚙️ 配置验证

# 验证配置文件
python -c "
from app.core.config import get_settings
try:
    settings = get_settings()
    print('✅ 配置文件加载成功')
    print(f'交易所: {settings.exchange_provider}')
    print(f'数据库: 已配置')
    print(f'通知: 已配置' if hasattr(settings, 'feishu_webhook_url') and settings.feishu_webhook_url else '未配置')
except Exception as e:
    print(f'❌ 配置文件错误: {e}')
"

# 测试API连接
python -c "
import asyncio
from app.services.exchanges.exchange_service_manager import get_exchange_service
async def test():
    try:
        service = await get_exchange_service()
        health = await service.health_check()
        print('✅ 交易所API连接成功' if health.get('overall_status') == 'healthy' else '❌ API连接失败')
    except Exception as e:
        print(f'❌ API连接失败: {e}')
asyncio.run(test())
"

🎯 启动服务

🖥️ 开发模式（推荐新手）

python main.py

🚀 后台运行模式

# Windows - 双击运行
start_service.bat

# 或使用命令行
python scripts/daemon_runner.py start

🔧 Windows服务模式（可选）

# 以管理员身份运行
scripts\install_service.bat

# 启动服务
net start TradingToolService

✅ 验证安装

1. 检查服务状态

# 运行状态检查脚本
python scripts/check_status.py

# 或手动检查API
curl http://localhost:8888/health

2. 访问Web界面

• 🌐 API文档: http://localhost:8888/docs
• ❤️ 健康检查: http://localhost:8888/health
• 📊 服务统计: http://localhost:8888/api/unified-data/service-stats

3. 预期健康检查输出

{
  "status": "healthy",
  "services": {
    "database": "connected",
    "kronos_ai": "loaded",
    "scheduler": "running",
    "exchange_service": "connected"
  },
  "timestamp": "2025-01-01T12:00:00Z"
}

📡 API接口文档

🎯 核心交易API

综合交易决策

POST /api/core-trading/analyze/{symbol}
# Kronos + 技术分析 + ML融合分析

GET /api/core-trading/signals  
# 获取所有交易信号

POST /api/core-trading/batch-analyze
{
  "symbols": ["BTC-USDT-SWAP", "ETH-USDT-SWAP"],
  "analysis_type": "integrated"
}

# 获取交易信号
GET /api/core-trading/signals/BTC-USDT-SWAP

📈 监控接口

# 负费率监控
GET /api/monitoring/funding-rates

# 异常检测
GET /api/monitoring/anomalies

# 系统健康检查
GET /health

🏗️ 项目架构

app/
├── api/                    # FastAPI 路由层
├── core/                   # 核心配置和基础设施
├── services/               # 业务逻辑层
│   ├── trading/           # 交易决策服务
│   ├── ml/                # AI/ML 服务
│   ├── monitoring/        # 监控服务
│   ├── notification/      # 通知服务
│   └── exchanges/         # 交易所接口
├── models/                # 数据模型
├── schemas/               # API 数据验证
└── utils/                 # 工具函数

🤖 AI 模型说明

Kronos AI 预测

• 模型: NeoQuasar/Kronos-Tokenizer-base
• 功能: 基于历史数据预测价格趋势
• 置信度: 0-1 评分系统
• 支持: CPU/GPU 加速

机器学习增强

• 异常检测: 识别市场异常波动
• 信号验证: 验证 AI 预测结果
• 自适应优化: 根据市场条件调整策略

📱 通知系统

支持多种通知渠道：

• 飞书机器人 - 实时交易信号推送
• 企业微信 - 重要事件通知
• 邮件通知 - 系统状态报告

🔧 开发指南

📝 代码规范

• 遵循 PEP 8 代码风格
• 使用类型注解
• 异步优先 (async/await)
• 完整的错误处理

🧪 测试

# 运行所有测试
pytest

# 运行特定测试
pytest tests/unit/
pytest tests/integration/

# 查看覆盖率
pytest --cov=app

📊 性能监控

• 内置性能指标收集
• API 响应时间监控
• AI 模型预测延迟跟踪
• 系统资源使用监控

🛠️ 故障排除

常见问题

Q: Kronos 模型加载失败

# 检查模型文件
ls models/cache/models--NeoQuasar--Kronos-Tokenizer-base/

# 重新下载模型
python -c "from app.services.ml.kronos_service import download_model; download_model()"

Q: 数据库连接失败

# 检查数据库配置
python -c "from app.core.config import get_settings; print(get_settings().database_url)"

# 测试连接
python -c "from app.core.database import test_connection; test_connection()"

Q: API 调用超时

• 检查网络连接
• 验证 API 密钥配置
• 查看日志文件 logs/app.log

📈 性能优化

资源配置建议

优化配置

# 高性能配置
KRONOS_CONFIG__USE_GPU=true
CACHE_CONFIG__MAX_CACHE_SIZE_MB=200
SERVICE_CONFIG__MAX_CONCURRENT_REQUESTS=16

📄 许可证

MIT License - 详见 LICENSE 文件

🤝 贡献指南

• 🐛 发现Bug - 提交Issue报告问题
• 💡 功能建议 - 提出新功能想法
• 📝 文档改进 - 完善文档和示例
• 🔧 代码贡献 - 提交Pull

---

⭐ 如果这个项目对你有帮助，请给个 Star！