ऐतिहासिक डेटा का बैकफिल
Late-arriving डेटा आम बात है. आपका daily_sales_load Dag सही चल रहा था, लेकिन 20-22 April के orders आज ही raw_orders में आए हैं, जिससे daily_summary में तीन खाली दिन रह गए. इसका समाधान बैकफिल है. Dag पहले से एक्टिव है, इसलिए आज का एक scheduled रन बैकफिल रनों के साथ दिखाई देगा जो आप बनाएँगे.
- टर्मिनल में
airflow backfill create --dag-id daily_sales_load --from-date 2026-04-20 --to-date 2026-04-22 --max-active-runs 1चलाइए. - बैकफिल रन पूरे होने के लिए लगभग 30 सेकंड प्रतीक्षा कीजिए.
- सभी रन देखने के लिए
airflow dags list-runs daily_sales_loadचलाइए.
आउटपुट में run_id कॉलम देखें. Backfill रनों की शुरुआत किस प्रीफिक्स से होती है?
यह अभ्यास पाठ्यक्रम का हिस्सा है
Airflow के साथ Data Pipelines बनाना
इंटरैक्टिव व्यावहारिक अभ्यास
हमारे इंटरैक्टिव अभ्यासों में से किसी एक के साथ सिद्धांत को व्यवहार में बदलें
अभ्यास शुरू करें