शुरू करेंमुफ़्त में शुरू करें

Databricks जॉब शेड्यूल करें

इस अभ्यास में, आप Databricks Workspace Client का उपयोग करके एक जॉब बनाएँगे जो निर्धारित समय पर HelloWorld नाम की नोटबुक चलाता है.

आप पहले सीख चुके हैं कि ऐसा जॉब कैसे बनाया जाए जिसे स्पष्ट रूप से ट्रिगर किया जा सके. इस फंक्शन में schedule पैरामीटर पास करके, आप क्रोन एक्सप्रेशन के ज़रिए जॉब को किसी खास समय पर चलने के लिए शेड्यूल कर सकते हैं.

इस अभ्यास में, आप मान सकते हैं कि एक प्री-डिफाइन्ड वैरिएबल cron_expression मौजूद है, जो रोज़ाना सुबह 3 बजे Eastern Time पर एक बार चलने के लिए क्रोन एक्सप्रेशन को दर्शाता है.

हमने पहले से WorkspaceClient() बना कर उसे w के रूप में स्टोर किया है, और एक notebook_path वैरिएबल भी मौजूद है.

यह अभ्यास पाठ्यक्रम का हिस्सा है

Python SDK के साथ Databricks

पाठ्यक्रम देखें

अभ्यास निर्देश

  • WorkspaceClient.jobs API में create() मेथड का उपयोग करके एक जॉब बनाएँ.
  • बनाए जा रहे जॉब को प्रीसेट cron_expression वैरिएबल का उपयोग करते हुए ईस्टर्न टाइमज़ोन में रोज़ाना सुबह 3 बजे चलने के लिए शेड्यूल करें.
  • जॉब को 25 सेकंड के बाद टाइमआउट होने के लिए कॉन्फ़िगर करें.

इंटरैक्टिव व्यावहारिक अभ्यास

इस अभ्यास को इस नमूना कोड को पूरा करके आज़माएँ।

# Create a job scheduled to run every day at 3 AM
created_job = w.jobs.____(name='sdk-dc-project-task',
                          tasks=[
                              jobs.Task(description="test",
                                        notebook_task=jobs.____(
                                            ____=notebook_path),
                                        task_key="my-key")
                          ],
                          # Schedule it to run every day at 3 AM
                          schedule=jobs.____(
                              quartz_cron_expression=____, ____="America/New_York"),

                          # The job should timeout after 25 seconds
                          ____=25,
                          )
कोड संपादित करें और चलाएँ