स्ट्रीम पर क्वेरी करना
Harbr की पाइपलाइन पूरे दिन logistics.staging_shipments में नए शिपमेंट रिकॉर्ड इनजेस्ट करती है. उसी टेबल पर staging_shipments_stream नाम की एक स्ट्रीम पहले से मौजूद है और हर insert को ट्रैक करने के लिए तैयार है. आपका काम है यह सुनिश्चित करना कि स्ट्रीम शुरुआत में खाली है, फिर दो नए staging shipments insert करना और स्ट्रीम पर क्वेरी करके देखना कि उसने क्या कैप्चर किया.
⚠️ डेटाबेस सेलेक्ट नहीं हो रहा, या "table not found" त्रुटि मिल रही है?
FROM क्लॉज़ में टेबल का पूरा path इस्तेमाल कीजिए. इसे बाएँ पैनल से लें: Databases टैब → अपने COURSE_… डेटाबेस को expand करें → टेबल चुनें → Copy name.
यह अभ्यास पाठ्यक्रम का हिस्सा है
Snowflake में डेटा पाइपलाइन ऑटोमेशन
इंटरैक्टिव व्यावहारिक अभ्यास
हमारे इंटरैक्टिव अभ्यासों में से किसी एक के साथ सिद्धांत को व्यवहार में बदलें
अभ्यास शुरू करें