CNPJ DataLake
Pipeline completo de ingestão e transformação de dados públicos de CNPJs da Receita Federal. Arquitetura em camadas Bronze → Silver → Gold com orquestração via Apache Airflow, processamento distribuído e múltiplas saídas para API, BI e Analytics.
Outros Projetos
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 integração com WhatsApp via Evolution API construído no n8n, com transcrição automática de áudios (speech-to-text), buffer inteligente de mensagens para consolidação de contexto e envio estruturado ao backend. Inclui controle de sessão, debounce de mensagens e registro persistente das interações.
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.
Implementação de arquitetura multiagente com separação de responsabilidades (Agente Classificador, Agente Executor, Agente Validador e Agente Supervisor). Orquestração via n8n com memória compartilhada e controle de estado, permitindo decisões dinâmicas e fluxos complexos de atendimento.
Servidor MCP (Model Context Protocol) responsável por expor ferramentas internas para agentes de IA, integrado a uma API proprietária. Permite execução segura de ações (consulta de dados, atualização de registros, disparo de eventos) com autenticação, auditoria e controle de permissões.
