事件驱动 LP 轮动系统 — 面向 Solana/Raydium/Meteora 的状态机驱动流动性管理
DEX / 链上数据采集
→ 指标增强派生 (metrics_derived)
→ AI 状态判断 (state + confidence)
→ 状态机迁移 (state_machine)
→ 轮动执行 / 回测 / 参数优化
→ Panel API 可视化
| 模块 | 职责 |
|---|---|
data_collector/ |
DEX 和链上数据采集 |
metrics_derived/ |
指标增强与特征工程 |
state_observer_ai/ |
AI 驱动的市场状态判断 |
state_machine/ |
状态迁移引擎 |
rotation_engine/ |
LP 轮动决策 |
execution/ |
链上执行层 |
backtest/ |
历史回测引擎 |
optimizer/ |
参数优化器 |
panel/ |
API 与可视化 |
- 语言: Python 3.12
- 框架: FastAPI, aiohttp, httpx
- 数据: Pydantic, JSON Schema, TypedDict
- 链上: Solana SDK, solders
- 测试: pytest, pytest-cov (AI 模块覆盖率 >85%)
- 状态机驱动: 先定义状态契约,再接模块 — 不是简单的价格预测
- 回测与执行分离: 回测引擎和执行引擎共享同一数据契约
- AI 安全: Schema 约束 AI 输出,防止字段污染
- 测试覆盖: AI 模块 >85% 覆盖率,Schema/AI 安全 20/20 通过
# 安装依赖
pip install -r requirements.txt
# 运行数据采集
python -m data_collector.main
# 运行回测
python -m backtest.main
# 启动 Panel API
python -m panel.appMIT