Snowflake में डेटा पाइपलाइन ऑटोमेशन
Emily Melhuish
Technical Curriculum Developer, Snowflake
उपयोग मामला:

External Tables
CREATE EXTERNAL TABLE logistics.supplier_inventory
WITH LOCATION = @harbr_stage/inventory/
FILE_FORMAT = (TYPE = 'PARQUET')
AUTO_REFRESH = TRUE;
-- पार्टनर इन्वेंटरी क्वेरी करें
SELECT supplier_id,
COUNT(*) AS file_count,
SUM(quantity) AS total_units
FROM logistics.supplier_inventory
WHERE delivery_date >= '2024-01-01'
GROUP BY supplier_id;
External tables
-- सीधे क्वेरी, लोड की ज़रूरत नहीं
SELECT * FROM
logistics.supplier_inventory
WHERE supplier_id = 'SUP-042';
COPY INTO से लोडिंग
-- एक बार लोड करें, तेज़ क्वेरी
COPY INTO logistics.delivery_events
FROM @harbr_stage/events/;
S3, Azure Blob या GCS से डेटा सही तरह कैसे पढ़ें?
Apache = ओपन टेबल फ़ॉर्मेट: डेटा किसी एक इंजन में लॉक नहीं

Snowflake-प्रबंधित
CREATE ICEBERG TABLE
logistics.shipments
CATALOG = 'SNOWFLAKE'
EXTERNAL_VOLUME = 'harbr_s3_vol'
BASE_LOCATION = 'iceberg/shipments/';
बाह्य-प्रबंधित
CREATE ICEBERG TABLE
logistics.partner_data
CATALOG = 'glue_catalog'
EXTERNAL_VOLUME = 'harbr_s3_vol'
CATALOG_TABLE_NAME =
'partner.deliveries';
Snowflake में डेटा पाइपलाइन ऑटोमेशन