Urmărirea Schimbărilor de Date (CDC) cu CREATE STREAM în Snowflake & dbt (Data Stack)

Un STREAM în Snowflake funcționează ca un mecanism nativ de Change Data Capture (CDC). Acesta înregistrează metadatele fiecărei modificări efectuate pe tabelul sursă (coloanele interne METADATA$ACTION, METADATA$ISUPDATE și METADATA$ROW_ID) de la un offset temporal fixat, permițând actualizarea incrementală a tabelelor aval fără scanarea integrală a istoricului.

-- Crearea stream-ului pe tabela de comenzi brute:
CREATE OR REPLACE STREAM stream_comenzi_noi ON TABLE raw_db.staging.comenzi;

-- Vizualizarea modificărilor neprocesate:
SELECT * FROM stream_comenzi_noi WHERE METADATA$ACTION = 'INSERT';