Modular, event-driven systematic trading framework and architectural blueprint for cloud-native quantitative execution with embedded risk controls and telemetry.
graph TD
subgraph Ingestion [Market Data Ingestion]
A[WebSocket Live Price Stream] --> B[Cycle Engine Loop]
C[REST Historical Data Feed] --> B
end
subgraph Evaluation [Strategy & Signal Processing]
B --> D[Strategy Evaluator]
D --> E[Technical Indicators & Alpha Signals]
end
subgraph Risk [Risk Management Guardrails]
E --> F[Risk Manager]
F --> G[Position Sizing Engine]
F --> H[Max Drawdown & Exposure Safeguards]
end
subgraph Execution [Execution & Telemetry]
G --> I[Order Routing Gateway]
I --> J[(Exchange Execution / Sandbox)]
I --> K[Telegram / Webhook Real-Time Alerts]
end
- Max Position Sizing: Enforces dynamic volatility-adjusted position caps per asset.
- Daily Drawdown Circuit Breaker: Halts all order generation if daily equity drawdown threshold is crossed.
- State Recovery & Idempotency: State persistence ensures safe daemon restarts without orphaned orders.
- Core Engine: Python 3.11, AsyncIO, NumPy, Pandas
- Infrastructure: Google Cloud Platform (Compute Engine / IAP), Docker, Systemd
- Telemetry: Telegram Bot API, Structured JSON Logging
Framework de trading sistemático y diseño de arquitectura modular para ejecución cuantitativa en la nube con control de riesgo y telemetría integrada.
graph TD
subgraph Ingesta [Ingesta de Datos de Mercado]
A[Stream de Precios en Vivo WebSocket] --> B[Bucle del Motor]
C[Feed REST de Datos Históricos] --> B
end
subgraph Evaluacion [Evaluación de Estrategia y Señales]
B --> D[Evaluador de Estrategias]
D --> E[Indicadores Técnicos y Señales Alpha]
end
subgraph Riesgo [Control de Riesgo y Salvaguardas]
E --> F[Gestor de Riesgo]
F --> G[Motor de Dimensionamiento de Posición]
F --> H[Límites de Drawdown y Exposición]
end
subgraph Ejecucion [Ejecución y Telemetría]
G --> I[Enrutador de Órdenes]
I --> J[(Ejecución en Exchange / Sandbox)]
I --> K[Alertas en Tiempo Real Telegram]
end
- Dimensionamiento Dinámico: Límites máximos por activo ajustados a la volatilidad.
- Disyuntor de Pérdida Diaria (Circuit Breaker): Suspensión automática de operaciones ante caídas predefinidas de capital.
- Recuperación de Estado: Persistencia determinista para reinicios automáticos sin órdenes huérfanas.
- Motor: Python 3.11, AsyncIO, NumPy, Pandas
- Infraestructura: Google Cloud Platform (Compute Engine / IAP), Docker, Systemd
- Telemetría: Telegram Bot API, Logging estructurado en JSON