Запити до історичних даних із Time Travel
Нічне пакетне завдання Snowy Peak завантажило 2 скасовані облікові записи до таблиці subscriptions. Команда даних хоче порівняти поточну кількість рядків із тим значенням, яке було безпосередньо перед запуском пакету. Функція Snowflake Time Travel дає змогу зробити це без будь-яких зовнішніх резервних копій.
Таблиця snowy_peak.subscriptions має стовпці subscription_id, user_email, plan, status, start_date і monthly_fee. Змінна сеансу $snapshot_ts містить мітку часу, зафіксовану безпосередньо перед запуском пакетного оновлення.
Ця вправа є частиною курсу
Архітектура Snowflake
Інструкції до вправи
- Використайте
AT (TIMESTAMP => ...), щоб виконати запит доsnowy_peak.subscriptionsу стані до пакетного оновлення. Як мітку часу використайте змінну сеансу$snapshot_ts. - Порахуйте рядки як
pre_update_count, щоб підтвердити, скільки підписок існувало до додавання 2 скасованих облікових записів.
Інтерактивна практична вправа
Спробуйте виконати цю вправу, доповнивши цей зразок коду.
-- Count subscriptions before the overnight batch update
SELECT COUNT(*) AS pre_update_count
FROM snowy_peak.subscriptions
AT (___ => ___);