Adquisiciones¶

Seis tablas en la app mangroove_adquisiciones: lo que NASA publicó (Producto), lo que el motor leyó para cada región (Recorte), las pasadas del satélite sobre cada región (Adquisicion), cómo se combinan, las brechas del instrumento y el registro de cada sincronización.

La distinción entre producto, recorte y adquisición es la decisión central del módulo. Un producto es un archivo de NASA; puede cubrir dos regiones (D-11). Un recorte es el trabajo de leer ese archivo para una región; puede fallar. Una adquisición es una pasada del satélite sobre una región; puede venir de dos frames, y puede ser reemplazada por un reproceso (RN-02).

Requerimientos cubiertos¶

• RF-M-01 a RF-M-06
• RF-M-24
• RF-O-05
• RF-O-06
• RF-O-08

Diagrama¶

---
config:
  elk:
    nodePlacementStrategy: NETWORK_SIMPLEX
  fontFamily: monospace
  layout: elk
---
classDiagram
    class Producto {
        +uuid id
        +varchar(150) granulo
        +varchar(60) coleccion
        +varchar(12) madurez
        +varchar(6) crid
        +smallint ciclo
        +smallint track
        +smallint frame
        +varchar(4) orbita
        +timestamptz inicio_at
        +timestamptz fin_at
        +timestamptz procesado_at
        +varchar(4) polarizaciones
        +text s3_url
        +text https_url
        +bigint bytes
        +timestamptz created_at
    }
    class Recorte {
        +uuid id
        +uuid producto_id
        +uuid region_id
        +varchar(12) estado
        +smallint intentos
        +text error
        +text motivo_descarte
        +varchar(255) archivo
        +char(64) sha256
        +bigint bytes
        +integer[] ventana
        +real pixel_m
        +integer epsg_nativo
        +real incidencia
        +varchar(10) mascara_modo
        +timestamptz recortado_at
    }
    class Adquisicion {
        +uuid id
        +uuid region_id
        +smallint track
        +varchar(4) orbita
        +smallint[] frames
        +timestamptz inicio_at
        +varchar(20) fecha_codigo
        +varchar(12) madurez
        +varchar(6) crid
        +real incidencia
        +real cobertura
        +varchar(255) grilla_archivo
        +char(64) grilla_sha256
        +boolean excluida
        +text motivo_exclusion
        +boolean reemplazada
        +uuid reemplaza_a_id
    }
    class AdquisicionRecorte {
        +uuid id
        +uuid adquisicion_id
        +uuid recorte_id
    }
    class Brecha {
        +uuid id
        +tstzrange rango
        +text motivo
        +text fuente_url
    }
    class Sincronizacion {
        +uuid id
        +uuid region_id
        +varchar(10) origen
        +uuid solicitada_por_id
        +varchar(12) estado
        +timestamptz inicio_at
        +timestamptz fin_at
        +integer n_encontrados
        +integer n_recortados
        +integer n_descartados
        +integer n_fallidos
        +bigint bytes_transferidos
        +text error
    }
    Producto "1" --> "*" Recorte
    Recorte "1" --> "0..1" AdquisicionRecorte
    Adquisicion "1" --> "1..*" AdquisicionRecorte
    Adquisicion "0..1" --> "0..1" Adquisicion : reemplaza_a

Producto¶

Un gránulo NISAR L2 GCOV tal como lo publica ASF. Sus metadatos no cambian: un reproceso es otro gránulo.

• Régimen: Solo inserción
• Volumen estimado: 100-300 filas por región y año
• Origen:

  • RF-M-01
  • RF-M-03

Columnas¶

Constraints¶

CONSTRAINT chk_producto_crid
CHECK (crid ~ '^P[0-9]{5}$')

CONSTRAINT chk_producto_madurez
CHECK (madurez IN ('beta', 'provisional', 'validado'))

CONSTRAINT chk_producto_orbita
CHECK (orbita IN ('asc', 'desc'))

CONSTRAINT chk_producto_tiempo
CHECK (fin_at > inicio_at)

Unicidad e índices¶

Recorte¶

El trabajo de leer un producto para una región, y su resultado en disco.

• Régimen: Mutable rastreada
• Volumen estimado: igual a Producto por región
• Origen:

  • RF-M-02
  • RF-M-24

Columnas¶

Constraints¶

CONSTRAINT chk_recorte_estado
CHECK (estado IN ('pendiente', 'recortado', 'descartado', 'fallido'))

CONSTRAINT chk_recorte_recortado_completo
CHECK (
  (estado = 'recortado') = (
    archivo <> '' AND sha256 IS NOT NULL AND recortado_at IS NOT NULL
    AND cardinality(ventana) = 4
  )
)

CONSTRAINT chk_recorte_descarte_motivo
CHECK ((estado = 'descartado') = (motivo_descarte <> ''))

CONSTRAINT chk_recorte_intentos
CHECK (intentos BETWEEN 0 AND 3)

Unicidad e índices¶

Triggers¶

Adquisicion¶

Una pasada del satélite sobre una región, formada por uno o dos recortes.

• Régimen: Mutable rastreada
• Volumen estimado: 80-120 filas por región y año
• Origen:

  • RF-M-04
  • RF-M-05
  • RF-M-06
  • RF-O-06

Columnas¶

Una adquisición es vigente cuando no fue reemplazada y no está excluida. El puntero va de la versión nueva a la vieja porque el reemplazo ocurre al insertar la nueva: en ese instante la vieja ya existe y la nueva todavía no. Solo las vigentes entran a corridas nuevas.

Constraints¶

CONSTRAINT chk_adquisicion_cobertura
CHECK (cobertura BETWEEN 0 AND 1)

CONSTRAINT chk_adquisicion_exclusion_motivo
CHECK (excluida = (motivo_exclusion <> ''))

CONSTRAINT chk_adquisicion_grilla_completa
CHECK ((grilla_archivo <> '') = (grilla_sha256 IS NOT NULL))

CONSTRAINT chk_adquisicion_no_se_reemplaza_a_si_misma
CHECK (reemplaza_a_id IS DISTINCT FROM id)

Unicidad e índices¶

Triggers¶

AdquisicionRecorte¶

Qué recortes forman cada adquisición. Una pasada que cae en dos frames tiene dos filas.

• Régimen: Solo inserción
• Volumen estimado: 1-2 filas por adquisición
• Origen: RF-M-04

Unicidad y triggers¶

trg_adquisicionrecorte_coherente (BEFORE INSERT) exige que el recorte esté recortado, sea de la misma región, del mismo track, órbita y CRID, y que su inicio esté a menos de dos minutos del de la adquisición.

Brecha¶

Un período sin datos del instrumento. Es global: una brecha de NISAR afecta a todas las regiones.

• Régimen: Mutable rastreada
• Volumen estimado: decenas de filas
• Origen: RN-17

CONSTRAINT excl_brecha_rango
EXCLUDE USING gist (rango WITH &&)

La primera migración la siembra con la brecha permanente del 27 de julio de 2026 a las 22:03:25 UTC al 10 de agosto de 2026 a las 00:55:27 UTC, publicada en la guía de usuario de NISAR.

Sincronizacion¶

Cada ejecución de la ingesta sobre una región.

• Régimen: Mutable rastreada
• Volumen estimado: 4 filas por región y día
• Origen:

  • RF-M-24
  • RF-O-08

CONSTRAINT chk_sincronizacion_origen
CHECK ((origen = 'manual') = (solicitada_por_id IS NOT NULL))

CONSTRAINT chk_sincronizacion_cierre
CHECK ((estado = 'en_curso') = (fin_at IS NULL))