Transformări Declarative Continue: CREATE DYNAMIC TABLE în Snowflake & dbt (Data Stack)

Dynamic Tables reprezintă evoluția modernă a vederilor materializate în Snowflake. În loc să creați manual Streams și Tasks pentru sincronizare incrementală, definiți doar interogarea SQL țintă și parametrul TARGET_LAG (ex: 5 minute). Snowflake monitorizează automat modificările surselor și reîmprospătează tabelul incremental fără intervenție umană.

CREATE OR REPLACE DYNAMIC TABLE analytics.dt_agregari_orare
  TARGET_LAG = '15 MINUTES'
  WAREHOUSE = TRANSFORM_WH
AS
  SELECT
    DATE_TRUNC('hour', data_comanda) AS ora,
    COUNT(DISTINCT comanda_id) AS total_comenzi,
    SUM(valoare_totala) AS venit_total
  FROM raw_db.staging.comenzi
  GROUP BY 1;