Build your ultimate AI agent
Descrierea cursului
Stăpânește instrumentele și tehnicile pentru construirea unor pipeline-uri de date fiabile și automatizate în Snowflake. Veți începe prin a învăța cum să ingerați date la scară largă — configurând stage-uri și formate de fișiere, încărcând date cu COPY INTO și alegând între încărcarea batch, Snowpipe și Snowpipe Streaming pentru diferite cerințe de latență și volum.
De acolo, vei dezvolta competențe de orchestrare a pipeline-urilor end-to-end: captarea modificărilor la nivel de rând cu streams, conectarea fluxurilor de lucru în mai mulți pași cu task DAGs și crearea de pipeline-uri declarative, auto-actualizate, cu dynamic tables. Vei învăța, de asemenea, când să apelezi la tabele externe și Iceberg pentru scenarii multi-engine și cloud-native.
A doua jumătate a cursului îți perfecționează abilitățile de interogare și transformare — extragerea și dezîncapsularea JSON-ului semi-structurat din coloanele VARIANT, aplicarea extensiilor de grupare și a funcțiilor window pentru analize avansate și încapsularea logicii reutilizabile în UDF-uri și proceduri stocate.
În cele din urmă, vei aborda performanța interogărilor: vei învăța să citești Query Profile din Snowflake pentru a identifica blocajele, să alegi instrumentul potrivit de optimizare — Search Optimization, Query Acceleration Service, clustering keys sau materialized views — și să scrii SQL prietenos cu cache-ul, care evită anti-pattern-urile comune ce degradează în tăcere performanța.
Cerințe prealabile
Nu există cerințe prealabile pentru acest curs
Curriculum
Structura cursului
1
Încărcarea, ingestia și conectivitatea datelor
Stăpânește pipeline-ul de ingestie a datelor în Snowflake — de la fișiere staged prin COPY INTO, Snowpipe și Snowpipe Streaming — și conectează Snowflake la ecosistemul mai larg de date prin conectori, drivere și instrumente de export.
- Etape, formate de fișiere și COPY INTO50 XP
- Clasificarea tipurilor de stage100 XP
- Gestionarea erorilor cu COPY INTO50 XP
- Snowpipe și Snowpipe Streaming50 XP
- Alegerea metodei potrivite de ingestie50 XP
- Caracteristicile metodelor de ingestie100 XP
- Descărcarea datelor și conectivitate50 XP
- Descărcarea datelor în Cloud Storage50 XP
- Mecanisme de conectivitate100 XP
2
Orchestrarea pipeline-urilor și obiectele de date
Construiește pipeline-uri de date robuste folosind orchestrarea nativă Snowflake — streams pentru capturarea modificărilor, tasks pentru planificare, tabele dinamice pentru transformare declarativă și tabele externe și Iceberg pentru stocare în formate deschise.
3
Interogarea și transformarea datelor
Interoghează JSON semi-structurat cu notație punct și FLATTEN, agregă date cu GROUPING SETS, ROLLUP și CUBE, calculează funcții de fereastră și încapsulează logică reutilizabilă în UDF-uri și proceduri stocate.
4
Performanța și optimizarea interogărilor
Profilează interogări în Snowsight, identifică blocajele cu QUERY_HISTORY, aplică Search Optimization, Query Acceleration Service, Automatic Clustering și Materialized Views, și scrie SQL care beneficiază de cele trei straturi de cache din Snowflake.
S
Automatizarea pipeline-urilor de date în Snowflake
Curs
finalizat
