Esta es la arquitectura que aplico en mis proyectos: de las fuentes al dashboard, con calidad, orquestación e infraestructura como código. Pulsa una pieza para ver qué hace y dónde la he construido. Y quítala para ver qué se rompe aguas abajo.
Elige la versión
La plataforma que montaría hoy en Google Cloud para una empresa mediana: captura de cambios desde las bases operativas, APIs y ficheros aterrizando en Cloud Storage, eventos por Pub/Sub, Dataflow en batch y en streaming, BigQuery por capas con Dataform, y consumo desde Looker Studio, Vertex AI, Sheets y una API. Debajo, lo que la mantiene viva: Composer, Dataplex, IAM, Terraform y observabilidad.
Prueba un escenario
Pieza quitada
Sin datos o desactualizado
Datos incompletos
Datos no fiables
Riesgo latente
El recorrido de un dato
Sigue un solo cambio de principio a fin. Cada paso ilumina su pieza en el diagrama.
1
Cambia un registro
RRHH actualiza el salario de un empleado en Cloud SQL.
2
Datastream lo captura
El cambio se lee del log de transacciones y se escribe como Avro en Cloud Storage en menos de un minuto, sin consultar la base.
3
Aterriza sin tocar
Queda en una ruta con la fecha. Nadie lo modifica jamás: si algo sale mal después, se reprocesa desde aquí.
4
Dataflow lo valida
Esa noche el job batch parsea el Avro, comprueba el esquema y escribe la fila en BigQuery bronze. Si no cumple, va a la tabla de rechazados con el motivo.
5
Dataform lo modela
Silver cierra la versión anterior del salario y abre la nueva con fecha de vigencia: historia completa, sin duplicados.
6
Pasa las aserciones
Clave única, salario dentro de rango, empleado existente en la dimensión. Si algo falla, gold no se toca y salta una alerta.
7
Se convierte en KPI
La tabla de hechos recalcula la brecha frente al salario de mercado de Eurostat para ese rol.
8
Vertex AI reevalúa
La predicción mensual actualiza el riesgo de salida del empleado y SHAP explica que la brecha salarial pesa menos que antes.
9
El manager lo ve
En Looker Studio el empleado sale de la lista de riesgo. Misma cifra en la hoja de finanzas, porque leen la misma vista gold.
Las capas, una a una
Qué es cada etapa, por qué existe, con qué servicios se monta y dónde la he construido.
1 · Fuentes
Qué es
Bases operativas en Cloud SQL, SaaS con API, eventos de apps y sensores, y ficheros de negocio.
Por qué existe
Cada tipo de fuente falla distinto: una base se satura, una API cambia formato, un fichero llega tarde. Por eso cada una tiene su método de ingesta.
Servicios
Cloud SQLAlloyDBAPIs RESTSFTPDrive
Dónde lo he hecho
RRHH, Slack, Eurostat y Adzuna en el TFM; GPS, clima y aire en CloudRISK; catálogos públicos en el monitor de precios.
2 · Ingesta
Qué es
Extractores que mueven datos sin transformarlos: Datastream captura cambios, Cloud Functions llama a las APIs, Pub/Sub recibe eventos y Cloud Run Jobs recoge ficheros.
Por qué existe
Separar extraer de transformar permite reintentar sin perder nada y cambiar una fuente sin tocar el resto.
Servicios
DatastreamCloud FunctionsPub/SubCloud Run JobsSecret Manager
Dónde lo he hecho
Walker como Cloud Run Job y tres topics de Pub/Sub en CloudRISK; extractores de Eurostat y Adzuna en el TFM.
3 · Landing y procesamiento
Qué es
Todo aterriza crudo e inmutable en Cloud Storage. Dataflow batch parsea y valida; Dataflow streaming aplica reglas en continuo; Dataproc Serverless reprocesa histórico con PySpark.
Por qué existe
Guardar el crudo antes de tocarlo es lo que permite reprocesar cuando algo sale mal, y procesar aparte permite escalar sin tocar el warehouse.
Pipeline stateful de Beam con antitrampas en CloudRISK; landing en Cloud Storage en el TFM.
4 · Bronze y estado
Qué es
BigQuery bronze guarda la historia sin transformar; Firestore guarda el presente que leen las apps; un servicio enriquece los textos con Vertex AI.
Por qué existe
Analítica y operación tienen necesidades opuestas: mucho volumen barato frente a lecturas instantáneas. Un almacén para cada una.
Servicios
BigQueryFirestoreCloud RunVertex AI
Dónde lo he hecho
Bronze normalizada y sentimiento de Slack en el TFM; saldo y mapa en Firestore en CloudRISK.
5 · Silver y gold con Dataform
Qué es
Modelos SQL versionados: silver limpia y da claves, las aserciones bloquean lo que no cumple, gold sirve hechos y KPIs, y las tablas de features alimentan al modelo.
Por qué existe
Es la capa donde se define una sola verdad. Cada métrica tiene dueño, fórmula y umbral escritos, y los tests garantizan que llega bien.
Servicios
DataformBigQueryBigQuery ML
Dónde lo he hecho
Vistas gold, catálogo de KPIs y aserciones en el TFM; modelos dbt cada cinco minutos en Calidad del aire.
6 · Consumo
Qué es
Looker Studio para decidir, Vertex AI para anticipar, Connected Sheets para finanzas y una API en Cloud Run para el producto.
Por qué existe
Todos leen la misma capa gold. No hay tres versiones del KPI según quién pregunte.
Servicios
Looker StudioVertex AIConnected SheetsCloud Run
Dónde lo he hecho
Centro de mando y modelo con SHAP en el TFM; backend FastAPI en CloudRISK; agente con Gemini en el Student Hub.
Transversal
Qué es
Composer orquesta, Dataplex cataloga, IAM y Secret Manager protegen, Terraform y Cloud Build despliegan, Logging y Billing vigilan.
Por qué existe
No mueven ni un dato, pero son la diferencia entre una demo y una plataforma que sobrevive al primer mes.