अर्ध-संरचित डेटा क्वेरी करना

Snowflake में डेटा पाइपलाइन ऑटोमेशन

Emily Melhuish

Technical Curriculum Developer, Snowflake

अर्ध-संरचित डेटा लोड करना

डेटा लोडिंग.png

¹ * Snowflake Learning Material

विभिन्न डेटा आकारों का प्रबंधन

Carrier A Carrier A JSON

Carrier B

Carrier B JSON

रूपांतरण उदाहरण

Screenshot 2026-05-11 at 5.56.34 pm.png

Snowflake डेटा प्रकार

श्रेणी	प्रकार	उदाहरण
संख्यात्मक	NUMBER, INT, FLOAT	`credits_used NUMBER(10,2)`
पाठ	VARCHAR, STRING, TEXT	`carrier_name VARCHAR`
दिनांक / समय	DATE, TIME, TIMESTAMP	`dispatch_date DATE`
बूलियन	BOOLEAN	`is_active BOOLEAN`
अर्ध-संरचित	VARIANT, OBJECT, ARRAY	`event_payload VARIANT`

VARIANT प्रकार

VARIANT अर्ध-संरचित डेटा ज्यों का त्यों संग्रहीत करता है: कोई स्कीमा आवश्यक नहीं
JSON, Parquet, Avro, ORC या XML सीधे लोड करें
डेटा संरचना क्वेरी समय पर हल होती है, लोड समय पर नहीं (schema-on-read)

COPY INTO shipment_events
FROM @harbr_stage/events/
FILE_FORMAT = (TYPE = 'JSON');

VARIANT वर्ड क्लाउड जो सभी अर्ध-संरचित डेटा प्रकार दिखाता है जिन्हें VARIANT रखता है: JSON, ARRAY, OBJECT, AVRO, PARQUET, SEMI-STRUCTURED

JSON में नेविगेट करना

उदाहरण JSON

{
  "shipment_id": "SHP-001",
  "carrier": { "name": "FastFreight" },
  "stops": [
    { "location": "Rotterdam Port" },
    { "location": "Amsterdam Hub" }
  ]
}

JSON नेविगेशन

संरचना पार करना:

<column>:<level1_element>.<level2_element>

SELECT 
event:id::STRING AS shipment_id
, event:carrier.name::STRING AS carrier
, event:stops[0]:location::STRING 
AS first_stop 
FROM shipment_events;

FLATTEN से ऐरे को पंक्तियों में बदलना

LATERAL FLATTEN का उपयोग

SELECT 
  s.event_data:shipment_id::STRING AS shipment_id,
  f.value:location::STRING AS stop,
  f.value:arrived_at::TIMESTAMP AS arrived_at 
FROM shipment_events s,
  LATERAL FLATTEN(input => s.event_data:stops) f;

चलें अभ्यास करें!

Snowflake में डेटा पाइपलाइन ऑटोमेशन