COPY INTO (Bulk Data Loading) este o componentă esențială în ecosistemul Snowflake & dbt. Încărcarea de mare viteză a milioanelor de fișiere JSON, CSV sau Parquet dintr-un stadiu S3/GCS în Snowflake.
Sintaxă și Utilizare Practică
Exemplu practic documentat pas cu pas:
-- Încărcare automată din bucket extern Amazon S3
COPY INTO TRANZACTII_RAW
FROM @stage_s3_lakehouse/tranzactii/2026/
FILE_FORMAT = (
TYPE = 'PARQUET'
COMPRESSION = 'SNAPPY'
)
PATTERN = '.*[.]parquet'
ON_ERROR = 'CONTINUE';
Bune Practici în Producție
- Eficiență Computațională: Aplicați predicate pushdown, filtrați din timp datele și evitați operațiunile de shuffle redundante.
- Calitatea Datelor: Definiți teste automate de integritate și monitorizați calitatea la fiecare transformare.
- Optimizare de Costuri: Folosiți încărcare incrementală și politici automate de auto-suspendare pentru resursele de calcul.