Zacznij terazZacznij za darmo

Odpytywanie streamu

Pipeline Harbr wczytuje nowe rekordy przesyłek do tabeli logistics.staging_shipments przez cały dzień. Stream o nazwie staging_shipments_stream jest już podłączony do tej tabeli i śledzi każdą operację wstawienia danych. Twoje zadanie to potwierdzić, że stream startuje jako pusty, a następnie wstawić dwie nowe przesyłki do tabeli staging i odpytać stream, aby zobaczyć, co udało mu się przechwycić.

⚠️ Nie możesz wybrać bazy danych albo pojawia się błąd „table not found"?

Użyj pełnej ścieżki do tabeli w klauzuli FROM. Znajdziesz ją w lewym panelu: zakładka Databases → rozwiń swoją bazę COURSE_… → wybierz tabelę → Copy name.

To ćwiczenie jest częścią kursu

Automatyzacja potoków danych w Snowflake

Zobacz kurs

Interaktywne ćwiczenie praktyczne

Przekształć teorię w praktykę dzięki jednemu z naszych interaktywnych ćwiczeń

Rozpocznij ćwiczenie