Interogarea unui stream
Pipeline-ul companiei Harbr ingerează înregistrări noi de transport în logistics.staging_shipments pe parcursul zilei. Un stream numit staging_shipments_stream este deja atașat acelui tabel și este pregătit să urmărească fiecare inserare. Sarcina ta este să confirmi că stream-ul pornește gol, apoi să inserezi două transporturi noi în staging și să interoghezi stream-ul pentru a vedea ce a capturat.
Folosește calea completă a tabelului în clauza ⚠️ Nu poți selecta o bază de date sau primești o eroare de tipul „table not found"?
FROM. O găsești în panoul din stânga: tab-ul Databases → extinde baza ta de date COURSE_… → selectează tabelul → Copy name.
Acest exercițiu face parte din cursul
Automatizarea pipeline-urilor de date în Snowflake
Exercițiu interactiv practic
Transformă teoria în practică cu unul dintre exercițiile noastre interactive
Începe exercițiul