FAVFrancisco Álvarez Varas

Cómo trabajo

Un pipeline de datos end-to-end, pieza a pieza

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
1Fuentes2Ingesta3Landing y procesamiento4Bronze y estado5Silver y gold · Dataform6Consumo
Bases operativasCloud SQL · AlloyDB
SaaS y APIsSalesforce · Search Console · Eurostat
Eventos de apps y dispositivosmóvil · web · sensores
Ficheros de negocioExcel · CSV · SFTP · Drive
Datastream · CDCcaptura de cambios sin cargar el origen
Cloud Functions · extractoresAPI → JSON en Cloud Storage
Pub/Subtopics · suscripciones · retención
Cloud Run Jobs · ficherosSFTP y Drive → Cloud Storage
Dataproc Serverless · PySparkrecargas históricas masivas
Cloud Storage · landingcrudo inmutable · particionado por fecha
Dataflow batchApache Beam · parseo y validación
Dataflow streamingBeam · ventanas · estado por clave
BigQuery · bronzetablas crudas particionadas y clusterizadas
Enriquecimiento NLPCloud Run + Vertex AI · sentimiento y temas
Firestore · estado en vivodocumentos reactivos para apps
BigQuery · silverDataform · limpieza, tipos, claves, SCD
Aserciones de calidadDataform assertions · unicidad · nulos · rangos
BigQuery · gold · martshechos, dimensiones y KPIs con definición
BigQuery ML · featurestablas de variables · baseline en SQL
Looker Studiodashboards con umbrales accionables
Vertex AI · modelo y endpointentrenamiento · registro · predicción · SHAP
Connected Sheets y exportacionesBigQuery → Sheets para finanzas
Cloud Run · APIFastAPI para apps y operaciones
Cloud Composer · AirflowDAGs · dependencias · reintentos · SLAs
IAM · Secret Manager · VPC Service Controlsmínimo privilegio · secretos · perímetro
Dataplex · catálogo, linaje y PIIqué significa cada tabla y quién la cuida
Terraform · Cloud Build · Artifact Registryinfraestructura y despliegues como código
Cloud Logging · Monitoring · Billinglogs, alertas, presupuestos y runbooks
  • 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. 1
    Cambia un registro

    RRHH actualiza el salario de un empleado en Cloud SQL.

  2. 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. 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. 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. 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. 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. 7
    Se convierte en KPI

    La tabla de hechos recalcula la brecha frente al salario de mercado de Eurostat para ese rol.

  8. 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. 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.
Servicios
Cloud StorageDataflowApache BeamDataproc Serverless
Dónde lo he hecho
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.
Servicios
Cloud ComposerDataplexIAMTerraformCloud BuildCloud Monitoring
Dónde lo he hecho
Terraform con un solo apply y CI/CD en CloudRISK y el Student Hub; catálogo y PII en Dataplex, runbook y costes en el TFM.