Заплануйте роботу Databricks
У цій вправі ви використаєте Databricks Workspace Client, щоб створити роботу, яка запускає ноутбук з назвою HelloWorld у запланований час.
Ви вже навчилися створювати роботу, яку можна запускати вручну. Якщо передати параметр schedule до цієї функції, ви можете запланувати запуск роботи у визначений час за допомогою cron-виразу.
У цій вправі припустімо, що є заздалегідь оголошена змінна cron_expression, яка представляє cron-вираз для запуску раз на день о 3-й годині ночі за східним часом.
Ми вже створили WorkspaceClient(), зберігши його як w, а також змінну notebook_path.
Ця вправа є частиною курсу
Databricks із Python SDK
Інструкції до вправи
- Скористайтеся методом
create()в APIWorkspaceClient.jobs, щоб створити роботу. - Заплануйте створювану роботу на щоденний запуск о 3-й годині ночі за східним часовим поясом, використовуючи наперед задану змінну
cron_expression. - Налаштуйте завершення роботи за тайм-аутом через 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,
)