Einen Databricks-Job planen
In dieser Übung erstellst du mit dem Databricks Workspace Client einen Job, der ein Notebook mit dem Namen HelloWorld zu einem geplanten Zeitpunkt ausführt.
Du hast bereits gelernt, wie man einen Job erstellt, der explizit ausgelöst werden kann. Indem du den Parameter schedule an diese Funktion übergibst, kannst du den Job mithilfe eines Cron-Ausdrucks zu einem bestimmten Zeitpunkt ausführen lassen.
In dieser Übung kannst du davon ausgehen, dass es eine vordefinierte Variable namens cron_expression gibt, die den Cron-Ausdruck repräsentiert, um einmal täglich um 3 Uhr morgens Eastern Time auszuführen.
Wir haben bereits den WorkspaceClient() erstellt und als w gespeichert sowie eine Variable notebook_path angelegt.
Diese Übung ist Teil des Kurses
<Kurs>Databricks mit dem Python-SDK</Kurs>Übungsanweisungen
- Verwende die Methode
create()in derWorkspaceClient.jobs-API, um einen Job zu erstellen. - Plane den zu erstellenden Job so, dass er jeden Tag um 3 Uhr morgens in der Eastern-Zeitzone mit der vordefinierten Variable
cron_expressionausgeführt wird. - Konfiguriere den Job so, dass er nach 25 Sekunden abbricht.
Interaktive praktische Übung
Versuche dich an dieser Übung, indem du diesen Beispielcode vervollständigst.
# 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,
)