Motore di elaborazione dei segnali in tempo reale per l’automazione del trading ad alta velocità

Architettura Principale

Pipeline di Elaborazione Multi-Simbolo

Il bot mantiene una pipeline di elaborazione continua che:

• Carica e mette in cache i dati storici delle candele per ogni simbolo monitorato
• Riceve in streaming i tick in tempo reale per aggiornare l'ultima candela attiva
• Esegue in parallelo oltre 30 algoritmi di segnale per ogni simbolo
• Filtra i segnali in base alle configurazioni attivate
• Scatena azioni (inserimento ordine o broadcast) quando le condizioni sono soddisfatte

Flusso dei Dati

Dati Kline Storici → Livello Cache → Motore di Elaborazione Segnali
         ↓ ↑
Stream Tick in Tempo Reale ──────────────────────────────┘
         ↓
Algoritmi di Segnale (30+) → Filtro Attivato → Router Azioni
         ↓ ↓
   Output Segnale ┌───────────┴───────────┐
                                    ↓ ↓
                       Inserimento Ordine   Broadcast
                       (se in volatility_   (se in volatility_
                        action list)        action_broadcast list)

Tipi di Segnali Supportati (oltre 30)

Segnali di Trend e Momentum

Segnali Direzionali Base

• UP — Rilevato movimento rialzista
• DOWN — Rilevato movimento ribassista

Volume e Price Action

• PUMP — Forte volatilità improvvisa al rialzo con picco di volume
• CRASH — Forte volatilità improvvisa al ribasso con crollo di volume
• SPIKE_PUMP — Spike estremo del prezzo al rialzo (richiede enable_spike_detection = true)
• SPIKE_CRASH — Spike estremo del prezzo al ribasso (richiede enable_spike_detection = true)

Segnali di Inversione e Recupero

• RECOVERY — Rimbalzo rapido dopo un forte calo
• REVERSAL — Inversione di tendenza confermata
• STOP_HUNT_RECOVERY — Caccia agli stop seguita da rimbalzo di recupero
• FISHER_STOP_HUNT_RECOVERY — Recupero confermato dal Fisher Transform
• STOP_HUNT_REVERSAL — Caccia agli stop seguita da inversione
• FISHER_STOP_HUNT_REVERSAL — Inversione confermata dal Fisher Transform

Accumulazione e Distribuzione

• ACCUMULATION — Consolidamento laterale con acquisti nascosti
• FISHER_ACCUMULATION — Accumulazione confermata dal Fisher Transform
• DISTRIBUTION — Fase di distribuzione che indica un trend ribassista
• FISHER_DISTRIBUTION — Distribuzione confermata dal Fisher Transform

Segnali di Breakout

• BREAKOUT_UP / FISHER_BREAKOUT_UP
• BREAKOUT_DOWN / FISHER_BREAKOUT_DOWN

Supporto e Resistenza

• SUPPORT_ABSORPTION — Assorbimento del prezzo su un forte supporto
• RESISTANCE_ABSORPTION — Assorbimento del prezzo vicino a una resistenza

Segnali da Indicatori Tecnici

Basati su RSI

• RSI_BUY — Ipervenduto (richiede enable_oversold_signal = true)
• RSI_SELL — Ipercomprato (richiede enable_overbought_signal = true)

Analisi del Volume

• VOLUME_SPIKE_BUY
• VOLUME_SPIKE_SELL

Momentum e Velocità

• MOMENTUM_BUY, MOMENTUM_SELL
• VELOCITY_BUY, VELOCITY_SELL

ATR, Bollinger, MACD, Divergenze

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

Segnali Avanzati Multi-Fattore

• 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

Segnali Smart Money a Lungo Termine

• LONGTERM_SMART_LONG_SIGNAL
• LONGTERM_SMART_SHORT_SIGNAL

Workflow di Elaborazione dei Segnali

Passo 1: Preparazione Dati

1. Caricamento dati storici kline da cache o API
2. Validazione completezza dati (gap, candele mancanti)
3. Inserimento ultimi tick nella candela attiva
4. Calcolo indicatori tecnici (RSI, MACD, ATR, Bollinger, ecc.)
5. Calcolo metriche derivate (delta volume, velocità, momentum)

Passo 2: Esecuzione Algoritmi di Segnale

Il motore esegue tutti gli algoritmi attivati in parallelo. Ogni algoritmo analizza il dataset preparato ed emette segnali con: tipo, direzione, forza, timestamp e punteggio di confidenza.

Passo 3: Filtraggio Segnali

I segnali passano attraverso più filtri prima dell'azione:

• Controllo Attivazione — I segnali devono essere abilitati nella configurazione (es. SPIKE_CRASH richiede enable_spike_detection).
• Filtro Azione Volatilità — Corrispondenza con supported_volatility_action per ordini automatici.
• Filtro Broadcast — Corrispondenza con supported_volatility_action_broadcast per notifiche.

Passo 4: Esecuzione Azioni

Inserimento Ordine Automatico

SE signal.type IN supported_volatility_action:
    → Inserisci ordine in base alla direzione del segnale
    → Applica regole di gestione del rischio
    → Registra dettagli ordine

Broadcast del Segnale

SE signal.type IN supported_volatility_action_broadcast:
    → Format dati segnale
    → Invia a Discord / Telegram / WhatsApp / altri canali

Esempio di Configurazione

# Trigger per inserimento ordini
supported_volatility_action:
  - "BUY"
  - "SELL"
  - "PUMP"
  - "CRASH"
# Trigger per broadcast (insieme più ampio per notifiche)
supported_volatility_action_broadcast:
  - "BUY"
  - "SELL"
  - "PUMP"
  - "CRASH"
  - "OFI_BUY"
  - "OFI_SELL"
  - "VOLUME_SPIKE_BUY"
  - "VOLUME_SPIKE_SELL"
  - "DIVERGENCE_BUY"
  - "DIVERGENCE_SELL"

Nota: Dopo aver modificato le impostazioni dei segnali, risincronizza i simboli (rimuovili da symbols.json e reimportali). Usa una lista broadcast più ampia rispetto alla lista azioni per monitorare senza esecuzione automatica.

Caratteristiche di Prestazione

Design Zero-Latency

• Cache in memoria per ridurre le chiamate API
• Aggiornamento streaming tick solo della candela attiva
• Elaborazione parallela su simboli e algoritmi
• Calcoli ottimizzati con riutilizzo dei valori intermedi

Scalabilità

• Gestisce migliaia di simboli contemporaneamente
• Elabora oltre 30 algoritmi per simbolo in millisecondi
• Supporta più timeframe per simbolo
• Scalabilità orizzontale con nodi di elaborazione aggiuntivi

Affidabilità

• Tolleranza ai guasti — continua anche se singoli segnali falliscono
• Validazione dati prima dell'elaborazione
• Degradazione graduale — salta simboli problematici
• Logging errori per il debug

Casi d'Uso

• High-Frequency Trading — Usa segnali SPIKE, PUMP, CRASH per entrate/uscite rapide
• Smart Money Following — Segui i pattern istituzionali con segnali LONGTERM_SMART
• Portafoglio Multi-Strategia — Esegui combinazioni su gruppi di simboli
• Gestione del Rischio — Usa solo segnali broadcast per revisione manuale
• Scansione di Mercato — Monitora centinaia di simboli per opportunità rare

Best Practices

1. Inizia in modo conservativo — Abilita pochi segnali all'inizio
2. Separa trading e monitoraggio — Lista broadcast più ampia della lista azioni
3. Backtest — Valida le combinazioni di segnali prima dell'uso live
4. Monitora le risorse — Assicura potenza di calcolo sufficiente per oltre 30 segnali/simbolo
5. Analizza i log — Tieni traccia di quali segnali performano meglio
6. Regola le soglie — Adatta la sensibilità alle condizioni di mercato

Requisiti Tecnici

• Connessione WebSocket stabile per lo streaming tick
• RAM sufficiente per la cache kline di tutti i simboli
• Rete a bassa latenza verso le API degli exchange
• CPU multi-core per elaborazione parallela
• Archiviazione persistente per storico segnali e analisi