JobHome · GCP · orientado a eventos
Pipeline multi-cliente de dados de telefonia
Problema
Chamadas recebidas de várias filas de atendimento chegavam por uma API de telefonia e precisavam virar tabelas analíticas separadas por cliente, sem intervenção manual a cada novo arquivo, fila ou cliente.
Solução
A extração em Python grava o payload bruto no Cloud Storage. O disparo é automático via Pub/Sub e Cloud Tasks: o job bronze, em Cloud Functions, recebe o caminho do arquivo (bronze_uri) como parâmetro. Um mapa fila → cliente em variável de ambiente direciona cada registro e as tabelas de cada cliente são criadas automaticamente no BigQuery. As camadas Silver e Gold padronizam e preparam o dado para consumo, e toda a infraestrutura é provisionada com Terraform.
Impacto
- Novo cliente ou fila entra por configuração, com tabela criada automaticamente.
- Processamento disparado por evento, sem execução manual.
- Infraestrutura reproduzível e versionada com Terraform.
Python / Cloud Storage / Pub/Sub / Cloud Tasks / Cloud Functions / BigQuery / Terraform


