Python के ज़रिए एक Dag शेड्यूल करें
आपने Dags बनाना अच्छी तरह सीखा है, लेकिन अब आप सप्ताह के किसी खास दिन और निश्चित समय पर एक विशेष Dag को शेड्यूल करना चाहते हैं. आप चाहते हैं कि कोड में यह जानकारी शामिल रहे ताकि कोई सहकर्मी ज़रूरत पड़ने पर Dag को किसी दूसरे सर्वर पर फिर से इंस्टॉल कर सके.
Airflow का dag ऑब्जेक्ट और उपयुक्त datetime मेथड आपके लिए इम्पोर्ट कर दिए गए हैं.
यह अभ्यास पाठ्यक्रम का हिस्सा है
Python में Apache Airflow परिचय
अभ्यास निर्देश
- Dag की start date को 1 नवंबर, 2025 पर सेट करें.
- क्रोन (cron) सिंटैक्स का उपयोग करके हर बुधवार दोपहर 12:30 बजे का शेड्यूल कॉन्फ़िगर करें.
इंटरैक्टिव व्यावहारिक अभ्यास
इस अभ्यास को इस नमूना कोड को पूरा करके आज़माएँ।
@dag(
dag_id='update_dataflows',
# Set to November 1, 2025
start_date=datetime(____),
# Every Wednesday at 12:30pm
schedule='____'
)
def update_dataflows():
@task
def pull_source_data():
pass
update_dataflows()