Запрос исторических данных с помощью Time Travel
Ночной пакетный процесс Snowy Peak загрузил в таблицу subscriptions две отменённые учётные записи. Команда по работе с данными хочет сравнить текущее количество строк с тем, что было непосредственно перед запуском пакетной задачи. Функция Time Travel в Snowflake позволяет сделать это без каких-либо внешних резервных копий.
Таблица 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, чтобы подтвердить, сколько подписок существовало до добавления двух отменённых учётных записей.
Интерактивное практическое упражнение
Попробуйте выполнить это упражнение, дополнив этот пример кода.
-- Count subscriptions before the overnight batch update
SELECT COUNT(*) AS pre_update_count
FROM snowy_peak.subscriptions
AT (___ => ___);