Saltar a contenido

Consolidación y Resiliencia — Canal de Ventas

Propuesta de valor

Asegurar que toda la cifra de venta de tiendas, eCommerce y suscripciones queda integrada en Google Cloud Platform y los sistemas operacionales, con mecanismos de recuperación automática y monitorización continua.

Contexto

El proyecto 2601-038 nace de la necesidad de garantizar que los datos de venta procedentes de múltiples orígenes (PoS, eCommerce, suscripciones) se integran de forma completa y correcta en GCP y el sistema RDO corporativo.

Hoy, si un ticket falla en Pub/Sub o Dataflow lo procesa de forma incompleta, no existe un mecanismo automatizado para detectarlo ni para reprocesarlo. Nos damos cuenta cuando ya es tarde.

Requisitos del proyecto

Funcionales

ID Requisito Ficha
RF01 Recuperación de tickets no integrados Ver ficha
RF02 Subida backups de cajas vía ESB-Karaf Ver ficha
RF03 Verificación backups contra integración Ver ficha
RF04 Suscripciones como transacciones de venta en GCP Ver ficha
RF05 Librería Java interoperable (bin2raw) Ver ficha
RF06 Sistema de monitorización y alertas Ver ficha
RF07 Control integración pedidos eCommerce (Yoda) Ver ficha
RF08 Monitorización datafeeds devoluciones eCom Ver ficha

Técnicos

ID Requisito Ficha
RT01 Dataflow deja todas las tablas en Capa Bronze Ver ficha
RT02 Tablas destino particionadas por fecha del ticket Ver ficha
RT03 Procesos dbt utilizan el nuevo campo particionado Ver ficha

Arquitectura de alto nivel

graph TB
    subgraph "Orígenes"
        POS["PoS Tiendas"]
        ECOM["eCommerce"]
        SUBS["Suscripciones"]
    end

    subgraph "Middleware"
        YODA["Yoda"]
        PUBSUB["Pub/Sub"]
    end

    subgraph "GCP — Procesamiento"
        DF["Dataflow"]
        BIN2RAW["bin2raw.jar"]
        BRONZE["Capa Bronze (GBQ)"]
        DBT["dbt (Silver)"]
    end

    subgraph "Sistemas destino"
        RDO["RDO Corporate"]
        SMART["Smart v2 (fuera de alcance)"]
    end

    subgraph "Resiliencia (este proyecto)"
        MON["Monitorización (RF06)"]
        REC["Recuperación (RF01/RF03)"]
        BACKUP["Backups Cajas (RF02)"]
    end

    POS --> YODA --> PUBSUB --> DF
    ECOM --> YODA
    SUBS -.->|RF04| PUBSUB
    DF --> BIN2RAW --> BRONZE --> DBT
    DF --> RDO
    MON -->|vigila| DF
    MON -->|vigila| PUBSUB
    REC -->|reprocesa| PUBSUB
    BACKUP -->|sube a GCS| DF

    style SMART stroke-dasharray: 5 5,stroke:#f66

Fuera de alcance

  • Ticket de gasolinera en GCP
  • Integración de datos de venta en Smart v2

Enlaces rápidos