Crypto Market Data Pipeline
Ecossistema completo de processamento de dados em tempo real. Monitoramento do mercado de criptomoedas através de conexões WebSocket, Apache Kafka e TA-Lib, com foco em alta escalabilidade, baixa latência e observabilidade profunda via Prometheus e Grafana.
Outros Projetos
Pipeline completo de ingestão e transformação de dados públicos de CNPJs. Armazenamento em HDFS com processamento distribuído via Apache Spark, orquestrado por Airflow dentro de containers Docker.
Dev Insights é um pipeline de ingestão de dados responsável por integrar com a API do WakaTime, extrair métricas de produtividade e persistir dados em PostgreSQL. Arquitetura baseada em dois serviços independentes (Orchestrator + API REST com FastAPI), containerizados com Docker Compose.
Fluxo de agente de IA com validações estruturadas (guardrails), análise de risco de resposta, controle de alucinação e sistema de evaluations automatizadas. Implementa checagens pré e pós-resposta, classificação de intenção, validação semântica e fallback para operador humano quando necessário.
