Motor de procesamiento de señales en tiempo real para automatización de trading de alta velocidad

Arquitectura Principal

Pipeline de Procesamiento Multi-Símbolo

El bot mantiene un pipeline de procesamiento continuo que:

• Carga y cachea datos históricos de velas para cada símbolo monitorizado
• Recibe streaming de ticks en vivo para actualizar la vela más reciente en tiempo real
• Ejecuta en paralelo más de 30 algoritmos de señal por símbolo
• Filtra las señales según las configuraciones habilitadas
(colocación de órdenes o difusión) cuando se cumplen las condiciones

Flujo de Datos

Datos Históricos Kline → Capa de Caché → Motor de Procesamiento de Señales
         ↓ ↑
Stream de Tick en Vivo ──────────────────────────────┘
         ↓
Algoritmos de Señal (30+) → Filtro Habilitado → Router de Acciones
         ↓ ↓
   Salida de Señal ┌───────────┴───────────┐
                                    ↓ ↓
                       Colocación de Órdenes   Difusión
                       (si está en volatility_ (si está en volatility_
                        action list)           action_broadcast list)

Tipos de Señales Soportadas (30+)

Señales de Tendencia y Momentum

Señales Direccionales Básicas

• UP — Movimiento alcista detectado
• DOWN — Movimiento bajista detectado

Volumen y Price Action

• PUMP — Volatilidad repentina fuerte al alza con explosión de volumen
• CRASH — Volatilidad repentina fuerte a la baja con colapso de volumen
• SPIKE_PUMP — Spike extremo de precio al alza (requiere enable_spike_detection = true)
• SPIKE_CRASH — Spike extremo de precio a la baja (requiere enable_spike_detection = true)

Señales de Reversión y Recuperación

• RECOVERY — Rebote rápido tras una caída significativa
• REVERSAL — Reversión confirmada de la dirección de la tendencia
• STOP_HUNT_RECOVERY — Caza de stops seguida de rebote de recuperación
• FISHER_STOP_HUNT_RECOVERY — Recuperación confirmada por Fisher Transform
• STOP_HUNT_REVERSAL — Caza de stops seguida de reversión
• FISHER_STOP_HUNT_REVERSAL — Reversión confirmada por Fisher Transform

Acumulación y Distribución

• ACCUMULATION — Consolidación lateral con compra sigilosa
• FISHER_ACCUMULATION — Acumulación confirmada por Fisher Transform
• DISTRIBUTION — Fase de distribución que indica tendencia bajista
• FISHER_DISTRIBUTION — Distribución confirmada por Fisher Transform

Señales de Breakout

• BREAKOUT_UP / FISHER_BREAKOUT_UP
• BREAKOUT_DOWN / FISHER_BREAKOUT_DOWN

Soporte y Resistencia

• SUPPORT_ABSORPTION — Absorción de precio en soporte fuerte
• RESISTANCE_ABSORPTION — Absorción de precio cerca de resistencia

Señales de Indicadores Técnicos

Basadas en RSI

• RSI_BUY — Sobreventa (requiere enable_oversold_signal = true)
• RSI_SELL — Sobrecompra (requiere enable_overbought_signal = true)

Análisis de Volumen

• VOLUME_SPIKE_BUY
• VOLUME_SPIKE_SELL

Momentum y Velocidad

• MOMENTUM_BUY, MOMENTUM_SELL
• VELOCITY_BUY, VELOCITY_SELL

ATR, Bollinger, MACD, Divergencia

• ATR_BREAKOUT_BUY / ATR_BREAKOUT_SELL
• BB_BUY / BB_SELL
• MACD_BUY / MACD_SELL
• DIVERGENCE_BUY / DIVERGENCE_SELL

Señales Avanzadas Multi-Factor

• COMBINED_BUY / COMBINED_SELL
• MTF_BUY / MTF_SELL
• CVD_BUY / CVD_SELL
• VWAP_BUY / VWAP_SELL
• RS_BUY / RS_SELL
• REGIME_BUY / REGIME_SELL
• CHOP_BUY / CHOP_SELL
• OFI_BUY / OFI_SELL
• ICHIMOKU_BUY / ICHIMOKU_SELL

Señales Smart Money a Largo Plazo

• LONGTERM_SMART_LONG_SIGNAL
• LONGTERM_SMART_SHORT_SIGNAL

Flujo de Procesamiento de Señales

Paso 1: Preparación de Datos

1. Cargar datos históricos kline desde caché o API
2. Validar integridad de datos (huecos, velas faltantes)
3. Fusionar los últimos ticks en la vela activa
4. Calcular indicadores técnicos (RSI, MACD, ATR, Bollinger, etc.)
5. Calcular métricas derivadas (delta de volumen, velocidad, momentum)

Paso 2: Ejecución de Algoritmos de Señal

El motor ejecuta concurrentemente todos los algoritmos habilitados. Cada algoritmo analiza el conjunto de datos preparado y emite señales con: tipo, dirección, fuerza, marca de tiempo y puntuación de confianza.

Paso 3: Filtrado de Señales

Las señales pasan por múltiples filtros antes de la acción:

• Chequeo de Habilitación — La señal debe estar activada en la configuración (ej. SPIKE_CRASH necesita enable_spike_detection).
• Filtro de Acción por Volatilidad — Coincidencia con supported_volatility_action para órdenes automáticas.
• Filtro de Difusión — Coincidencia con supported_volatility_action_broadcast para notificaciones.

Paso 4: Ejecución de Acciones

Colocación Automática de Órdenes

SI signal.type ESTÁ EN supported_volatility_action:
    → Colocar orden según la dirección de la señal
    → Aplicar reglas de gestión de riesgo
    → Registrar detalles de la orden

Difusión de Señal

SI signal.type ESTÁ EN supported_volatility_action_broadcast:
    → Formatear datos de la señal
    → Enviar a Discord / Telegram / WhatsApp / otros canales

Ejemplo de Configuración

# Disparadores de colocación de órdenes
supported_volatility_action:
  - "BUY"
  - "SELL"
  - "PUMP"
  - "CRASH"
# Disparadores de difusión (conjunto más amplio para notificaciones)
supported_volatility_action_broadcast:
  - "BUY"
  - "SELL"
  - "PUMP"
  - "CRASH"
  - "OFI_BUY"
  - "OFI_SELL"
  - "VOLUME_SPIKE_BUY"
  - "VOLUME_SPIKE_SELL"
  - "DIVERGENCE_BUY"
  - "DIVERGENCE_SELL"

Nota: Tras cambiar la configuración de señales, resincroniza los símbolos (elimínalos de symbols.json y vuelve a importarlos). Usa una lista de difusión más amplia que la lista de acciones para monitorear sin ejecución automática.

Características de Rendimiento

Diseño de Latencia Cero

• Caché en memoria para reducir llamadas API
• Streaming de ticks solo actualiza la vela activa
• Procesamiento paralelo entre símbolos y algoritmos
• Cálculos optimizados que reutilizan valores intermedios

Escalabilidad

• Maneja miles de símbolos simultáneamente
• Procesa 30+ algoritmos por símbolo en milisegundos
• Soporta múltiples marcos temporales por símbolo
• Escala horizontalmente con nodos de procesamiento adicionales

Fiabilidad

• Tolerancia a fallos — continúa aunque fallen señales individuales
• Validación de datos antes del procesamiento
• Degradación elegante — omite símbolos problemáticos
• Registro detallado de errores para depuración

Casos de Uso

• Trading de Alta Frecuencia — Señales SPIKE, PUMP, CRASH para entradas/salidas ultrarrápidas
• Seguimiento de Smart Money — Detecta patrones institucionales con señales LONGTERM_SMART
• Portafolio Multi-Estrategia — Ejecuta combinaciones en grupos de símbolos
• Gestión de Riesgo — Solo difusión para revisión manual
• Escaneo de Mercado — Monitorea cientos de símbolos en busca de oportunidades raras

Mejores Prácticas

1. Comienza de forma conservadora — Habilita pocos señales al principio
2. Separa trading de monitoreo — Lista de difusión más amplia que la lista de acciones
3. Backtesting obligatorio — Valida combinaciones de señales antes del uso en vivo
4. Monitorea recursos — Asegura potencia suficiente para 30+ señales por símbolo
5. Revisa los logs — Rastrea qué señales tienen mejor rendimiento
6. Ajusta umbrales — Ajusta la sensibilidad según las condiciones del mercado

Requisitos Técnicos

• Conexión WebSocket estable para streaming de ticks
• RAM suficiente para caché de kline de todos los símbolos
• Red de baja latencia hacia las APIs de los exchanges
• CPU multi-core para procesamiento paralelo
• Almacenamiento persistente para historial de señales y analíticas