Interogarea datelor istorice cu Time Travel
Job-ul batch de noapte al Snowy Peak a încărcat 2 conturi anulate în tabela subscriptions. Echipa de date vrea să compare numărul actual de înregistrări cu cel de dinainte de rularea batch-ului. Time Travel din Snowflake face acest lucru posibil fără niciun backup extern.
Tabela snowy_peak.subscriptions are coloanele subscription_id, user_email, plan, status, start_date și monthly_fee. Variabila de sesiune $snapshot_ts reține timestamp-ul capturat imediat înainte de rularea actualizării batch.
Acest exercițiu face parte din cursul
Arhitectura Snowflake
Instrucțiuni pentru exercițiu
- Folosește
AT (TIMESTAMP => ...)pentru a interogasnowy_peak.subscriptionsașa cum era înainte de actualizarea batch. Folosește variabila de sesiune$snapshot_tsca timestamp. - Numără înregistrările ca
pre_update_countpentru a confirma câte abonamente existau înainte ca cele 2 conturi anulate să fie adăugate.
Exercițiu interactiv practic
Încearcă acest exercițiu completând acest cod de exemplu.
-- Count subscriptions before the overnight batch update
SELECT COUNT(*) AS pre_update_count
FROM snowy_peak.subscriptions
AT (___ => ___);