Motor de processamento de sinais em tempo real para automação de trading em alta velocidade

Arquitetura Principal

Pipeline de Processamento Multi-Símbolos

O bot mantém uma pipeline de processamento contínua que:

• Carrega e armazena em cache dados históricos de kline (velas) para cada símbolo monitorado
• Recebe streaming de ticks em tempo real para atualizar a vela mais recente em tempo real
• Executa em paralelo mais de 30 algoritmos de sinal para cada símbolo
• Filtra os sinais com base nas configurações habilitadas
• Dispara ações (colocação de ordens ou broadcast) quando as condições são atendidas

Fluxo de Dados

Dados Históricos Kline → Camada de Cache → Motor de Processamento de Sinais
         ↓ ↑
Stream de Tick ao Vivo ──────────────────────────────┘
         ↓
Algoritmos de Sinal (30+) → Filtro Habilitado → Roteador de Ações
         ↓ ↓
   Saída do Sinal ┌───────────┴───────────┐
                                    ↓ ↓
                       Colocação de Ordem   Broadcast
                       (se estiver em volatility_ (se estiver em volatility_
                        action list)           action_broadcast list)

Tipos de Sinais Suportados (30+)

Sinais de Tendência & Momentum

Sinais Direcionais Básicos

• UP — Movimento de alta detectado
• DOWN — Movimento de baixa detectado

Volume & Price Action

• PUMP — Forte volatilidade súbita para cima com explosão de volume
• CRASH — Forte volatilidade súbita para baixo com queda de volume
• SPIKE_PUMP — Spike extremo de preço para cima (requer enable_spike_detection = true)
• SPIKE_CRASH — Spike extremo de preço para baixo (requer enable_spike_detection = true)

Sinais de Reversão & Recuperação

• RECOVERY — Rebound rápido após queda significativa
• REVERSAL — Reversão confirmada da direção da tendência
• STOP_HUNT_RECOVERY — Caça a stops seguida de rebound de recuperação
• FISHER_STOP_HUNT_RECOVERY — Recuperação confirmada pelo Fisher Transform
• STOP_HUNT_REVERSAL — Caça a stops seguida de reversão
• FISHER_STOP_HUNT_REVERSAL — Reversão confirmada pelo Fisher Transform

Acumulação & Distribuição

• ACCUMULATION — Consolidação lateral com compra discreta
• FISHER_ACCUMULATION — Acumulação confirmada pelo Fisher Transform
• DISTRIBUTION — Fase de distribuição indicando tendência de baixa
• FISHER_DISTRIBUTION — Distribuição confirmada pelo Fisher Transform

Sinais de Breakout

• BREAKOUT_UP / FISHER_BREAKOUT_UP
• BREAKOUT_DOWN / FISHER_BREAKOUT_DOWN

Suporte & Resistência

• SUPPORT_ABSORPTION — Absorção de preço em suporte forte
• RESISTANCE_ABSORPTION — Absorção de preço próximo à resistência

Sinais de Indicadores Técnicos

Baseados em RSI

• RSI_BUY — Sobre-vendido (requer enable_oversold_signal = true)
• RSI_SELL — Sobre-comprado (requer enable_overbought_signal = true)

Análise de Volume

• VOLUME_SPIKED_BUY
• VOLUME_SPIKE_SELL

Momentum & Velocidade

• MOMENTUM_BUY, MOMENTUM_SELL
• VELOCITY_BUY, VELOCITY_SELL

ATR, Bollinger, MACD, Divergência

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

Sinais Avançados Multi-Fator

• 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

Sinais Smart Money de Longo Prazo

• LONGTERM_SMART_LONG_SIGNAL
• LONGTERM_SMART_SHORT_SIGNAL

Fluxo de Processamento de Sinais

Passo 1: Preparação dos Dados

1. Carregar dados históricos de kline do cache ou API
2. Validar integridade dos dados (gaps, velas faltando)
3. Inserir os últimos ticks na vela ativa
4. Calcular indicadores técnicos (RSI, MACD, ATR, Bollinger, etc.)
5. Calcular métricas derivadas (delta de volume, velocidade, momentum)

Passo 2: Execução dos Algoritmos de Sinal

O motor executa todos os algoritmos habilitados simultaneamente. Cada algoritmo analisa o conjunto de dados preparado e emite sinais contendo: tipo, direção, força, timestamp e score de confiança.

Passo 3: Filtragem de Sinais

Os sinais passam por múltiplos filtros antes da ação:

• Verificação de Ativação — O sinal precisa estar habilitado na config (ex: SPIKE_CRASH requer enable_spike_detection).
• Filtro de Ação por Volatilidade — Comparado com supported_volatility_action para ordens automáticas.
• Filtro de Broadcast — Comparado com supported_volatility_action_broadcast para notificações.

Passo 4: Execução de Ações

Colocação Automática de Ordens

SE signal.type ESTIVER EM supported_volatility_action:
    → Colocar ordem conforme direção do sinal
    → Aplicar regras de gerenciamento de risco
    → Registrar detalhes da ordem

Broadcast do Sinal

SE signal.type ESTIVER EM supported_volatility_action_broadcast:
    → Formatar dados do sinal
    → Enviar para Discord / Telegram / WhatsApp / outros canais

Exemplo de Configuração

# Gatilhos para colocação de ordens
supported_volatility_action:
  - "BUY"
  - "SELL"
  - "PUMP"
  - "CRASH"
# Gatilhos para broadcast (conjunto mais amplo para notificações)
supported_volatility_action_broadcast:
  - "BUY"
  - "SELL"
  - "PUMP"
  - "CRASH"
  - "OFI_BUY"
  - "OFI_SELL"
  - "VOLUME_SPIKE_BUY"
  - "VOLUME_SPIKE_SELL"
  - "DIVERGENCE_BUY"
  - "DIVERGENCE_SELL"

Observação: Após alterar as configurações de sinais, resincronize os símbolos (remova de symbols.json e reimporte). Use uma lista de broadcast mais ampla que a lista de ações para monitoramento sem execução automática.

Características de Performance

Design Zero-Latency

• Cache em memória para reduzir chamadas à API
• Streaming de ticks atualiza apenas a vela ativa
• Processamento paralelo entre símbolos e algoritmos
• Cálculos otimizados que reutilizam valores intermediários

Escalabilidade

• Gerencia milhares de símbolos simultaneamente
• Processa mais de 30 algoritmos por símbolo em milissegundos
• Suporta múltiplos timeframes por símbolo
• Escala horizontalmente com nós de processamento extras

Confiabilidade

• Tolerância a falhas — continua mesmo se sinais individuais falharem
• Validação de dados antes do processamento
• Degradação graciosa — ignora símbolos problemáticos
• Log de erros para depuração

Casos de Uso

• High-Frequency Trading — Use sinais SPIKE, PUMP, CRASH para entradas/saídas rápidas
• Seguimento de Smart Money — Acompanhe padrões institucionais com sinais LONGTERM_SMART
• Portfólio Multi-Estratégia — Execute combinações em grupos de símbolos
• Gerenciamento de Risco — Use apenas broadcast para revisão manual
• Varredura de Mercado — Monitore centenas de símbolos em busca de oportunidades raras

Melhores Práticas

1. Comece de forma conservadora — Habilite poucos sinais no início
2. Separe trading de monitoramento — Lista de broadcast mais ampla que a lista de ações
3. Faça backtest — Valide combinações de sinais antes do uso ao vivo
4. Monitore recursos — Garanta capacidade suficiente para 30+ sinais por símbolo
5. Analise os logs — Veja quais sinais têm melhor desempenho
6. Ajuste os limiares — Adapte a sensibilidade às condições atuais do mercado

Requisitos Técnicos

• Conexão WebSocket estável para streaming de ticks
• RAM suficiente para cache de kline de todos os símbolos
• Rede de baixa latência para APIs das exchanges
• CPU multi-core para processamento paralelo
• Armazenamento persistente para histórico de sinais e análises