ScheduleRecurrence 类
定义管道 Schedule 的频率、间隔和开始时间。
ScheduleRecurrence 还允许指定时区以及重复周期的小时数、分钟数或周数。
初始化计划定期。
它还允许指定时区以及重复周期的小时、分钟或周天数。
- 继承
-
builtins.objectScheduleRecurrence
构造函数
ScheduleRecurrence(frequency, interval, start_time=None, time_zone=None, hours=None, minutes=None, week_days=None, time_of_day=None)
参数
名称 | 说明 |
---|---|
frequency
必需
|
用于描述计划触发频率的时间单位。 可以是“分钟”、“小时”、“天”、“周”或“月”。 |
interval
必需
|
指定计划触发频率的值,即计划再次触发之前需等待的时间单位数。 |
start_time
|
描述开始日期和时间的日期/时间对象。 日期/时间对象的 tzinfo 应为 none,使用 如果 默认值: None
|
time_zone
|
指定 默认值: None
|
hours
|
如果为频率指定“天”或“周”,可以从 0 到 23 范围内指定一个或多个整数(用逗号分隔),作为一天中要运行工作流的时间点。
例如,如果指定“10”、“12”和“14”,则会将上午 10 点、中午 12 点和下午 2 点作为小时标记。 注意:只能使用 默认值: None
|
minutes
|
如果为频率指定“天”或“周”,可以从 0 到 59 范围内指定一个或多个整数(用逗号分隔),作为要运行工作流的分钟。 例如,可以指定“30”作为分钟标记并使用前面示例中的当天小时时间,这样,便可以指定10:30 AM、12:30 PM 和 2:30 PM 作为开始时间。 注意:只能使用 默认值: None
|
week_days
|
如果为频率指定“周”,则可以指定一天或多天(用逗号分隔)作为运行工作流的时间:“周一”、“周二”、“周三”、“周四”、“周五”、“周六”和“周日”。 默认值: None
|
time_of_day
|
如果为频率指定“天”或“周”,则可以将计划的时间指定为以 hh:mm 形式表示的字符串。 例如,如果指定“15:30”,则计划将在下午 3:30 运行。 注意:可以使用 默认值: None
|
frequency
必需
|
用于描述计划触发频率的时间单位。 可以是“分钟”、“小时”、“天”、“周”或“月”。 |
interval
必需
|
指定计划触发频率的值,即计划再次触发之前需等待的时间单位数。 |
start_time
必需
|
描述开始日期和时间的日期/时间对象。 datetime 对象的 tzinfo 应为 none,如果需要,请使用 time_zone 属性指定时区。 也可以是以下格式的字符串:YYYY-MM-DDThh:mm:ss。 如果提供 None,则第一个工作负载将立即运行,并且根据计划运行未来的工作负载。 如果开始时间是过去的时间,则第一个工作负荷将在下一个计算的运行时间运行。 如果 |
time_zone
必需
|
指定start_time的时区。 如果提供 None,则使用 UTC。 |
hours
必需
|
如果为频率指定“天”或“周”,可以从 0 到 23 范围内指定一个或多个整数(用逗号分隔),作为一天中要运行工作流的时间点。 例如,如果指定“10”、“12”和“14”,则会将上午 10 点、中午 12 点和下午 2 点作为小时标记。 注意:只能使用time_of_day或小时和分钟。 |
minutes
必需
|
如果为频率指定“天”或“周”,可以从 0 到 59 范围内指定一个或多个整数(用逗号分隔),作为要运行工作流的分钟。 例如,可以指定“30”作为分钟标记并使用前面示例中的当天小时时间,这样,便可以指定10:30 AM、12:30 PM 和 2:30 PM 作为开始时间。 注意:只能使用time_of_day或小时和分钟。 |
week_days
必需
|
如果为频率指定“Week”,则可以指定一个或多个天数(用逗号分隔)来运行工作流:“星期一”、“星期二”、“星期三”、“星期四”、“星期五”、“星期六”和“星期日” |
time_of_day
必需
|
如果为频率指定“天”或“周”,则可以将计划的时间指定为以 hh:mm 形式表示的字符串。 例如,如果指定“15:30”,则计划将在下午 3: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)
下面是有效 ScheduleRecurrences 的一些示例:
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()