Pipelines ELT · CDC incluído

Dê forma aos seus dados. Pipelines ELT visuais com CDC incluído

Pipelines visuais de extração, transformação e carga — com CDC incluído desde o plano de entrada e um conector HTTP que a IA configura sozinha. O poder de um data stack moderno, por uma fração do custo das ferramentas tradicionais.

customers_full_sync ao vivo
pg customers extract · cdc
My orders extract · incr
fx customer_360 transform · sql
destino load · upsert
1.4M linhas / exec
98.7% taxa de sucesso
2m 14s duração média
Conecta bancos, APIs e arquivos onde seus dados já vivem
pgPostgreSQL MyMySQL MSSQL Server MMongoDB OrOracle {}REST APIs GSGoogle Sheets XlExcel { }JSON </>XML
Tudo em um só fluxo

Todo o pipeline, sob controle.

Do banco de origem ao destino — modele, agende e observe cada passo sem sair do canvas. Destinos warehouse (Snowflake, BigQuery) chegando em breve.

Pipelines visuais

Monte o fluxo extract → transform → load arrastando steps. Inspecione o DAG e leia o histórico completo de execução de cada step.

Conectores de origem

PostgreSQL, MySQL, SQL Server, Oracle e MongoDB com sync incremental, full e CDC — além de um conector HTTP genérico que lê a spec da sua API.

Transformações

Regras de conversão por coluna — cast, trim, regex, mapas de valor, datas. Incremental multi-tabela com upsert por chave primária.

Agendamento

Execuções por cron a partir de 5 em 5 minutos ou manuais. Acompanhe taxa de sucesso, duração e linhas processadas a cada execução.

Multi-workspace

Isolamento por cliente com subdomínio próprio. Entre com Google ou senha — seus dados nunca cruzam entre tenants.

Pronto para produção

Observabilidade de execução, retries automáticos e alertas. Quando algo falha, você vê o step exato, o erro e o watermark.

Como funciona

Três passos da origem ao insight.

1 Conectar

Conecte a origem

Aponte o Januss para um banco ou API. Nós inspecionamos o schema e listamos cada tabela disponível — escolha o que precisar.

2 Modelar

Modele a transformação

Mapeie colunas, defina regras de conversão e escreva transforms em SQL. Escolha sync full, incremental ou CDC por tabela.

3 Executar

Agende e monitore

Defina um agendamento por cron e acompanhe. Cada execução registra status, duração e linhas — falhas mostram o step exato.

AI-assisted

O conector HTTP que lê sua API por você.

Forneça uma spec OpenAPI ou Swagger e o Januss entende seus endpoints, paginação e schema automaticamente. A autenticação assistida por IA resolve o handshake — tokens, refresh, headers — para você conectar qualquer API REST sem escrever código de cola.

  • Interpreta OpenAPI / Swagger em endpoints prontos para uso
  • Autenticação com IA: OAuth, API keys, bearer tokens
  • Resolve paginação e mapeamento de respostas aninhadas automaticamente
connect · stripe-api.yaml
lendo openapi.yaml … 48 endpoints encontrados
auth detectada: OAuth2 · bearer
paginação resolvida: cursor
schema mapeado: charges (22 colunas)
pronto para extrair
Transformações confiáveis

Converta e valide cada coluna — sem surpresas.

Defina regras de conversão por coluna e diga o que fazer quando um valor não converte. Depois valide o resultado transformado com SQL antes que ele chegue ao destino.

  • Converta tipos por coluna: string → decimal e o inverso, para inteiro e datas.
  • Ajuste o case sensitive de textos — upper, lower e capitalize.
  • Em erro de conversão, escolha: falhar a execução ou gravar null.
  • Valide o resultado com SQL — se a consulta acusar, a carga é bloqueada.
transform · customer_360 regras de coluna
amount string decimal erro → null
qty string integer erro → falha
email text lowercase case
validação pós-transform
-- bloqueia a carga se houver linha inválida
SELECT count(*) AS invalidos
FROM customer_360
WHERE amount IS NULL OR qty < 0;
-- esperado: 0 · caso contrário a execução falha
Roda na sua infraestrutura

Sincronize fontes locais sem abrir seu firewall.

O Proxy agente do Januss roda dentro da sua rede. A extração da origem e as transformações acontecem no seu servidor local — o dado bruto nunca é enviado para a nuvem. Só metadados de orquestração trafegam, por uma conexão de saída.

  • Sem regras de firewall de entrada — o agente só faz conexões de saída.
  • Extração e transformação executam no seu servidor local.
  • O dado sensível permanece na sua rede — a nuvem apenas orquestra.
  • Feito para empresas que não podem expor dados à nuvem.
sua rede · on-premise
DB fonte local extract
Proxy agente transform · local
Januss cloud orquestração · agendamento
Contato

Fale com a gente.

Converse com a gente para conhecer a ferramenta e solicite seu acesso antecipado. Estamos a um e-mail ou WhatsApp de distância.