ScheduleRecurrence Класс

Определяет частоту, интервал и время начала конвейера Schedule.

ScheduleRecurrence также позволяет указывать часовой пояс и часы, минуты или дни недели для повторения.

Инициализация повторения расписания.

Он также позволяет указать часовой пояс и часы, минуты или дни недели для повторения.

Наследование
builtins.object
ScheduleRecurrence

Конструктор

ScheduleRecurrence(frequency, interval, start_time=None, time_zone=None, hours=None, minutes=None, week_days=None, time_of_day=None)

Параметры

frequency
str
Обязательно

Единица времени, используемая для указания частоты срабатывания расписания: Может принимать значение Minute, Hour, Day, Week или Month.

interval
int
Обязательно

Значение, указывающее, как часто расписание срабатывает на основе частоты, т. е. количество единиц времени, которое необходимо выждать, прежде чем расписание сработает снова.

start_time
datetime или str
значение по умолчанию: None

Объект DateTime, описывающий дату и время начала. Свойство tzinfo объекта DateTime должно иметь значение None. При необходимости используйте свойство time_zone для указания часового пояса. Этот параметр также можно указать в виде строки в следующем формате: YYYY-MM-DDThh:mm:ss. При значении None первая рабочая нагрузка выполняется мгновенно, а будущие рабочие нагрузки выполняются на основе расписания. Если время запуска находится в прошлом, то первая рабочая нагрузка будет выполняться при следующем расчетном времени выполнения.

Если start_time соответствует week_days и time_of_day (или hours и minutes), то первая рабочая нагрузка не выполняется в start_time, а выполняется в следующее расчетное время выполнения.

time_zone
TimeZone
значение по умолчанию: None

Указание часового пояса start_time. При значении None используется время в формате UTC.

hours
list[int]
значение по умолчанию: None

Если для частоты задать значение Day или Week, то можно указать одно или несколько целых чисел от 0 до 23, разделенных запятыми, в качестве часов дня, когда будет запускаться рабочий процесс. Например, если указать 10, 12 и 14, вы получите часовые метки 10:00, 12:00 и 14:00. Примечание. Можно использовать только time_of_day или hours и minutes.

minutes
list[int]
значение по умолчанию: None

Если для частоты задать значение Day или Week, то можно указать одно или несколько целых чисел от 0 до 59, разделенных запятыми, в качестве минут часа, когда будет запускаться рабочий процесс. Например, если указать 30 минут и использовать предыдущий пример для часов, то вы получите 10:30, 12:30 и 14:30. Примечание. Можно использовать только time_of_day или hours и minutes.

week_days
list[str]
значение по умолчанию: None

Если для частоты задать значение Week, то можно указать один или несколько дней, разделенных запятыми, когда будет запускаться рабочий процесс: "Monday" (Понедельник), "Tuesday" (Вторник), "Wednesday" (Среда), "Thursday" (Четверг), "Friday" (Пятница), "Saturday" (Суббота) и "Sunday" (Воскресенье).

time_of_day
str
значение по умолчанию: None

Если для частоты задать значение Day или Week, то можно указать время суток, в течение которого расписание будет выполняться в виде строки в формате "чч:мм". Например, если указать значение "15:30", расписание будет выполняться в 15:30. Примечание. Можно использовать only time_of_day или hours и minutes.

frequency
str
Обязательно

Единица времени, используемая для указания частоты срабатывания расписания: Может принимать значение Minute, Hour, Day, Week или Month.

interval
int
Обязательно

Значение, указывающее, как часто расписание срабатывает на основе частоты, т. е. количество единиц времени, которое необходимо выждать, прежде чем расписание сработает снова.

start_time
datetime или str
Обязательно

Объект DateTime, описывающий дату и время начала. Значение tzinfo объекта datetime должно быть none. При необходимости используйте свойство time_zone, чтобы указать часовой пояс. Также может быть строкой в следующем формате: ГГГГ-ММ-ДДЧч:мм:сс. Если указан параметр Нет, первая рабочая нагрузка запускается мгновенно, а будущие рабочие нагрузки выполняются по расписанию. Если время запуска находится в прошлом, то первая рабочая нагрузка будет выполняться при следующем расчетном времени выполнения.

Если start_time соответствует week_days и time_of_day (или hours и minutes), то первая рабочая нагрузка не выполняется в start_time, а выполняется в следующее расчетное время выполнения.

time_zone
TimeZone
Обязательно

Укажите часовой пояс start_time. При значении None используется время в формате UTC.

hours
list[int]
Обязательно

Если для частоты задать значение Day или Week, то можно указать одно или несколько целых чисел от 0 до 23, разделенных запятыми, в качестве часов дня, когда будет запускаться рабочий процесс. Например, если указать 10, 12 и 14, вы получите часовые метки 10:00, 12:00 и 14:00. Примечание. Можно использовать только time_of_day или часы и минуты.

minutes
list[int]
Обязательно

Если для частоты задать значение Day или Week, то можно указать одно или несколько целых чисел от 0 до 59, разделенных запятыми, в качестве минут часа, когда будет запускаться рабочий процесс. Например, если указать 30 минут и использовать предыдущий пример для часов, то вы получите 10:30, 12:30 и 14:30. Примечание. Можно использовать только time_of_day или часы и минуты.

week_days
list[str]
Обязательно

Если вы указываете "Неделя" для частоты, можно указать один или несколько дней, разделенных запятыми, если вы хотите запустить рабочий процесс: "Понедельник", "Вторник", "Среда", "Четверг", "Пятница", "Суббота" и "Воскресенье".

time_of_day
str
Обязательно

Если для частоты задать значение Day или Week, то можно указать время суток, в течение которого расписание будет выполняться в виде строки в формате "чч:мм". Например, если указать значение "15:30", расписание будет выполняться в 15:30. Примечание. Можно использовать только time_of_day или часы и минуты.

Комментарии

ScheduleRecurrence используется при создании расписания для конвейера следующим образом:


   from azureml.pipeline.core import Schedule, ScheduleRecurrence

   recurrence = ScheduleRecurrence(frequency="Hour", interval=12)
   schedule = Schedule.create(workspace, name="TestSchedule", pipeline_id=pipeline.id,
                              experiment_name="experiment_name", recurrence=recurrence)

Ниже приведены примеры допустимых объектов ScheduleRecurrence:


   from azureml.pipeline.core import ScheduleRecurrence

   # Submit the Pipeline every 15 minutes
   recurrence = ScheduleRecurrence(frequency="Minute", interval=15)
   # Submit the Pipeline every 2 weeks on Monday and Wednesday at 6:30pm UTC
   recurrence = ScheduleRecurrence(frequency="Week", interval=2, week_days=["Monday", "Wednesday"],
                                   time_of_day="18:30")
   # Submit the Pipeline on the first day of every month starting November 1, 2019 at 9AM
   recurrence = ScheduleRecurrence(frequency="Month", interval=1, start_time="2019-11-01T09:00:00")
   # Submit the Pipeline every hour on the 55th minute starting on January 13th, 2020 at 12:55pm
   # if the specified start time is in the past, the first workload is run at the next future 55th minute
   # of the hour.
   recurrence = ScheduleRecurrence(frequency="Hour", interval=1, start_time="2020-01-13T12:55:00")

Методы

validate

Проверка повторения расписания.

validate

Проверка повторения расписания.

validate()