Compartilhar via

ScheduleRecurrence Classe

  • Referência

Define a frequência, o intervalo e a hora de início de um Schedule de pipeline.

ScheduleRecurrence também permite que você especifique o fuso horário e as horas, os minutos ou os dias da semana para a recorrência.

Inicializar uma recorrência de agendamento.

Ele também permite especificar o fuso horário e as horas ou minutos ou dias da semana para a recorrência.

Herança
builtins.object
ScheduleRecurrence

Construtor

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

Parâmetros

frequency
str
Obrigatório

A unidade de tempo que descreve a frequência com que o agendamento é acionado. Pode ser "Minuto", "Hora", "Dia", "Semana" ou "Mês".

interval
int
Obrigatório

Um valor que especifica com que frequência o agendamento é disparado com base na frequência, que é o número de unidades de tempo a aguardar até que o agendamento seja acionado novamente.

start_time
datetime ou str
valor padrão: None

Um objeto datetime que descreve a data e a hora de início. O tzinfo do objeto datetime deve ser None, use a propriedade time_zone para especificar um fuso horário, se necessário. Você também pode especificar esse parâmetro como uma cadeia de caracteres neste formato: AAAA-MM-DDThh:mm:ss. Se nenhuma for fornecida, a primeira carga de trabalho será executada instantaneamente e as cargas de trabalho futuras serão executadas com base na agenda. Se a hora de início estiver no passado, a primeira carga de trabalho será executada no próximo tempo de execução calculado.

Se start_time corresponder a week_days e time_of_day (ou hours e minutes ), a primeira carga de trabalho não é executada em start_time, mas em vez disso é executada no próximo tempo de execução calculado.

time_zone
TimeZone
valor padrão: None

Especifique o fuso horário de start_time. Se nenhum for fornecido, será usado o UTC.

hours
list[int]
valor padrão: None

Se você selecionar "Dia" ou "Semana" para frequência, poderá selecionar um ou mais números inteiros, de 0 a 23, separados por vírgulas, como as horas do dia nas quais você deseja executar o fluxo de trabalho. Por exemplo, se você especificar "10", "12" e "14", você obterá 10h, 12h e 14h como as marcas de hora. Observação: somente time_of_day ou hours e minutes podem ser usados.

minutes
list[int]
valor padrão: None

Se você selecionar "Dia" ou "Semana" para frequência, poderá selecionar um ou mais números inteiros, de 0 a 59, separados por vírgulas, como os minutos da hora nos quais você deseja executar o fluxo de trabalho. Por exemplo, você pode especificar "30" como a marca de minutos e, usando o exemplo anterior como as horas do dia, você obtém 10h30, 12h30 e 14h30. Observação: somente time_of_day ou hours e minutes podem ser usados.

week_days
list[str]
valor padrão: None

Se você selecionar "Semana" para frequência, poderá selecionar um ou mais dias, separados por vírgulas, nos quais deseja executar o fluxo de trabalho: “segunda-feira”, “terça-feira”, “quarta-feira”, “quinta-feira”, “Sexta-feira”, “sábado” e “domingo”.

time_of_day
str
valor padrão: None

Se você especificar "dia" ou "semana" para frequência, poderá especificar uma hora do dia para que o agendamento seja executado como uma cadeia de caracteres no formato hh:mm. Por exemplo, se você especificar "15:30", a agenda será executada: às 15h30. Observação: only time_of_day ou hours e minutes podem ser usados.

frequency
str
Obrigatório

A unidade de tempo que descreve a frequência com que o agendamento é acionado. Pode ser "Minuto", "Hora", "Dia", "Semana" ou "Mês".

interval
int
Obrigatório

Um valor que especifica com que frequência o agendamento é disparado com base na frequência, que é o número de unidades de tempo a aguardar até que o agendamento seja acionado novamente.

start_time
datetime ou str
Obrigatório

Um objeto datetime que descreve a data e a hora de início. O tzinfo do objeto datetime não deve ser nenhum, use time_zone propriedade para especificar um fuso horário, se necessário. Também pode ser uma cadeia de caracteres nesse formato: YYYY-MM-DDThh:mm:ss. Se Nenhum for fornecido, a primeira carga de trabalho será executada instantaneamente e as cargas de trabalho futuras serão executadas com base no agendamento. Se a hora de início estiver no passado, a primeira carga de trabalho será executada no próximo tempo de execução calculado.

Se start_time corresponder a week_days e time_of_day (ou hours e minutes ), a primeira carga de trabalho não é executada em start_time, mas em vez disso é executada no próximo tempo de execução calculado.

time_zone
TimeZone
Obrigatório

Especifique o fuso horário do start_time. Se nenhum for fornecido, será usado o UTC.

hours
list[int]
Obrigatório

Se você selecionar "Dia" ou "Semana" para frequência, poderá selecionar um ou mais números inteiros, de 0 a 23, separados por vírgulas, como as horas do dia nas quais você deseja executar o fluxo de trabalho. Por exemplo, se você especificar "10", "12" e "14", você obterá 10h, 12h e 14h como as marcas de hora. Observação: somente time_of_day ou horas e minutos podem ser usados.

minutes
list[int]
Obrigatório

Se você selecionar "Dia" ou "Semana" para frequência, poderá selecionar um ou mais números inteiros, de 0 a 59, separados por vírgulas, como os minutos da hora nos quais você deseja executar o fluxo de trabalho. Por exemplo, você pode especificar "30" como a marca de minutos e, usando o exemplo anterior como as horas do dia, você obtém 10h30, 12h30 e 14h30. Observação: somente time_of_day ou horas e minutos podem ser usados.

week_days
list[str]
Obrigatório

Se você especificar "Semana" para frequência, poderá especificar um ou mais dias, separados por vírgulas, quando quiser executar o fluxo de trabalho: "Segunda", "Terça", "Quarta", "Quinta", "Sexta", "Sábado" e "Domingo"

time_of_day
str
Obrigatório

Se você especificar "dia" ou "semana" para frequência, poderá especificar uma hora do dia para que o agendamento seja executado como uma cadeia de caracteres no formato hh:mm. Por exemplo, se você especificar "15:30", a agenda será executada: às 15h30. Observação: somente time_of_day ou horas e minutos podem ser usados.

Comentários

Uma ScheduleRecurrence é usada ao criar um Agendamento para um Pipeline da seguinte forma:


   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)

Veja a seguir alguns exemplos de ScheduleRecurrences válidos:


   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")

Métodos

validate

Validar a recorrência do agendamento.

validate

Validar a recorrência do agendamento.

validate()