Odpytywanie danych historycznych za pomocą Time Travel
Nocne zadanie wsadowe Snowy Peak załadowało 2 anulowane konta do tabeli subscriptions. Zespół ds. danych chce porównać bieżącą liczbę wierszy z tą sprzed uruchomienia zadania wsadowego. Time Travel w Snowflake umożliwia to bez konieczności korzystania z zewnętrznych kopii zapasowych.
Tabela snowy_peak.subscriptions zawiera kolumny: subscription_id, user_email, plan, status, start_date i monthly_fee. Zmienna sesyjna $snapshot_ts przechowuje znacznik czasu zarejestrowany tuż przed uruchomieniem aktualizacji wsadowej.
To ćwiczenie jest częścią kursu
Architektura Snowflake
Instrukcje do ćwiczenia
- Użyj
AT (TIMESTAMP => ...), aby odpytać tabelęsnowy_peak.subscriptionsw stanie sprzed aktualizacji wsadowej. Jako znacznik czasu podaj zmienną sesyjną$snapshot_ts. - Zlicz wiersze jako
pre_update_count, aby sprawdzić, ile subskrypcji istniało przed dodaniem 2 anulowanych kont.
Interaktywne ćwiczenie praktyczne
Spróbuj tego ćwiczenia, uzupełniając ten przykładowy kod.
-- Count subscriptions before the overnight batch update
SELECT COUNT(*) AS pre_update_count
FROM snowy_peak.subscriptions
AT (___ => ___);