Schedule Класс

Ссылка

Определяет расписание для отправки конвейера.

После публикации конвейера можно использовать расписание для отправки конвейера во время указанного интервала времени или при обнаружении изменений в расположении хранилища BLOB-объектов.

Инициализация расписания.

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

Schedule

Конструктор

Schedule(workspace, id, name, description, pipeline_id, status, recurrence, datastore_name, polling_interval, data_path_parameter_name, continue_on_step_failure, path_on_datastore, _schedule_provider=None, pipeline_endpoint_id=None)

Параметры

Имя	Описание
workspace Обязательно	Workspace Объект рабочей области, которому будет принадлежать это расписание.
id Обязательно	str Идентификатор расписания.
name Обязательно	str Имя расписания.
description Обязательно	str Описание расписания.
pipeline_id Обязательно	str Идентификатор конвейера, который будет отправляться по расписанию.
status Обязательно	str Состояние расписания: Active или Disabled.
recurrence Обязательно	ScheduleRecurrence Повторение расписания для конвейера.
datastore_name Обязательно	str Имя хранилища данных для отслеживания появления измененных или добавленных BLOB-объектов. Примечание. 1) хранилища данных виртуальной сети не поддерживаются. 2) Тип проверки подлинности для хранилища данных должен иметь значение "Ключ учетной записи".
polling_interval Обязательно	int Время в минутах между опросами измененных или добавленных больших двоичных объектов.
data_path_parameter_name Обязательно	str Имя параметра конвейера пути к данным для задания, которому необходимо присвоить измененный путь к большому двоичному объекту.
continue_on_step_failure Обязательно	bool Следует ли продолжать выполнение других шагов в отправленном PipelineRun, если шаг завершается ошибкой. Если значение предоставлено, оно переопределит параметр continue_on_step_failure для конвейера.
path_on_datastore Обязательно	str Необязательный элемент. Путь в хранилище данных для отслеживания измененных или добавленных больших двоичных объектов. Примечание. path_on_datastore будет указывать на хранилище данных, размещенное в контейнере, поэтому фактический путь, отслеживаемый расписанием, будет выглядеть так: “контейнер/путь_к_хранилищу_данных”. В противном случае отслеживается контейнер хранилища данных. Добавления и изменения, внесенные в папку, вложенную по отношению к path_on_datastore, не отслеживаются. Поддерживается только для расписаний хранилища данных.
_schedule_provider	<xref:azureml.pipeline.core._aeva_provider._AevaScheduleProvider> Поставщик расписания. значение по умолчанию: None
workspace Обязательно	Workspace Объект рабочей области, которому будет принадлежать это расписание.
id Обязательно	str Идентификатор расписания.
name Обязательно	str Имя расписания.
description Обязательно	str Описание расписания.
pipeline_id Обязательно	str Идентификатор конвейера, который будет отправляться по расписанию.
status Обязательно	str Состояние расписания: Active или Disabled.
recurrence Обязательно	ScheduleRecurrence Повторение расписания для конвейера.
datastore_name Обязательно	str Имя хранилища данных для отслеживания появления измененных или добавленных BLOB-объектов. Примечание. Хранилища данных виртуальной сети не поддерживаются.
polling_interval Обязательно	int Время в минутах между опросами измененных или добавленных больших двоичных объектов.
data_path_parameter_name Обязательно	str Имя параметра конвейера пути к данным для задания, которому необходимо присвоить измененный путь к большому двоичному объекту.
continue_on_step_failure Обязательно	bool Следует ли продолжать выполнение других шагов в отправленном PipelineRun, если шаг завершается ошибкой. Если значение предоставлено, оно переопределит параметр continue_on_step_failure для конвейера.
path_on_datastore Обязательно	str Необязательный элемент. Путь в хранилище данных для отслеживания измененных или добавленных больших двоичных объектов. Примечание. path_on_datastore будет указывать на хранилище данных, размещенное в контейнере, поэтому фактический путь, отслеживаемый расписанием, будет выглядеть так: “контейнер/путь_к_хранилищу_данных”. В противном случае отслеживается контейнер хранилища данных. Добавления и изменения, внесенные в папку, вложенную по отношению к path_on_datastore, не отслеживаются. Поддерживается только для расписаний хранилища данных.
_schedule_provider Обязательно	<xref:azureml.pipeline.core._aeva_provider._AevaScheduleProvider> Поставщик расписания.
pipeline_endpoint_id	str Идентификатор конечной точки конвейера, который будет отправляться по расписанию. значение по умолчанию: None

Поддерживаются два типа расписаний. Первый использует повторение по времени для отправки конвейера по заданному расписанию. Второй отслеживает AzureBlobDatastore на предмет добавленных или измененных BLOB-объектов и отправляет конвейер при обнаружении изменений.

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

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="helloworld", recurrence=recurrence)

Это расписание будет отправлять предоставленный PublishedPipeline каждые 12 часов. Отправленный конвейер будет создан в рамках эксперимента с именем HelloWorld.

Чтобы создать расписание, которое будет активировать PipelineRuns в случае изменений в расположении хранилища BLOB-объектов, укажите хранилище данных и связанные сведения о данных при создании расписания.


   from azureml.pipeline.core import Schedule
   from azureml.core.datastore import Datastore

   datastore = Datastore(workspace=ws, name="workspaceblobstore")

   schedule = Schedule.create(workspace, name="TestSchedule", pipeline_id="pipeline_id"
                              experiment_name="helloworld", datastore=datastore,
                              polling_interval=5, path_on_datastore="file/path")

Обратите внимание, что указывать параметры polling_interval и path_on_datastore необязательно. Параметр polling_interval указывает частоту опроса для отслеживания изменений в хранилище данных, по умолчанию — 5 минут. Параметр path_on_datastore позволяет указать, какая папка в хранилище данных должна отслеживаться на предмет изменений. Если задано значение None, отслеживается контейнер хранилища данных. Примечание. Добавление или изменение BLOB-объектов во вложенных папках path_on_datastore или контейнера хранилища данных (если параметр path_on_datastore не задан) не обнаруживается.

Кроме того, если конвейер был создан, чтобы использовать DataPath PipelineParameter для описания входных данных этапа, задействуйте параметр data_path_parameter_name при создании расписания, активируемого хранилищем данных, чтобы задать входные данные согласно измененному файлу при отправке PipelineRun расписанием.

В следующем примере, когда расписание запускает PipelineRun, в качестве значения input_data PipelineParameter будет задан файл, который был изменен или добавлен.


   from azureml.pipeline.core import Schedule
   from azureml.core.datastore import Datastore

   datastore = Datastore(workspace=ws, name="workspaceblobstore")

   schedule = Schedule.create(workspace, name="TestSchedule", pipeline_id="pipeline_id",
                              experiment_name="helloworld", datastore=datastore,
                              data_path_parameter_name="input_data")

Подробные сведения о расписаниях: https://aka.ms/pl-schedule.

Методы

create	Создание расписания для конвейера. Указание повторения для расписания на основе времени или указание хранилища данных, polling_interval и data_path_parameter_name (последние два параметра не обязательны), чтобы создать расписание, которое будет отслеживать расположение хранилища данных на предмет изменений и дополнений.
create_for_pipeline_endpoint	Создание расписания для конечной точки конвейера. Указание повторения для расписания на основе времени или указание хранилища данных, polling_interval и data_path_parameter_name (последние два параметра не обязательны), чтобы создать расписание, которое будет отслеживать расположение хранилища данных на предмет изменений и дополнений.
disable	Установка значения Disabled для расписания, в результате чего оно становится недоступным для выполнения.
enable	Установка значения Active для расписания, в результате чего оно становится доступным для выполнения.
get	Получение расписания с заданным идентификатором.
get_all	Получение всех расписаний в текущей рабочей области. НЕ РЕКОМЕНДУЕТСЯ. Этот метод является устаревшим. Используйте вместо него метод list.
get_last_pipeline_run	Получение последнего выполнения конвейера, отправленного по расписанию. Возвращает значение None, если выполнения не отправлялись.
get_pipeline_runs	Получение выполнений конвейера, созданных на основе расписания.
get_schedules_for_pipeline_endpoint_id	Получение всех расписаний для заданного идентификатора конечной точки конвейера.
get_schedules_for_pipeline_id	Получение всех расписаний для заданного идентификатора конвейера.
list	Получение всех расписаний в текущей рабочей области.
load_yaml	Загрузка и чтение файла YAML для получения параметров расписания. Файл YAML — это еще один способ передачи параметров расписания для создания расписания.
update	Обновление расписания.

create

Создание расписания для конвейера.

Указание повторения для расписания на основе времени или указание хранилища данных, polling_interval и data_path_parameter_name (последние два параметра не обязательны), чтобы создать расписание, которое будет отслеживать расположение хранилища данных на предмет изменений и дополнений.

static create(workspace, name, pipeline_id, experiment_name, recurrence=None, description=None, pipeline_parameters=None, wait_for_provisioning=False, wait_timeout=3600, datastore=None, polling_interval=5, data_path_parameter_name=None, continue_on_step_failure=None, path_on_datastore=None, _workflow_provider=None, _service_endpoint=None)

Параметры

Имя	Описание
workspace Обязательно	Workspace Объект рабочей области, которому будет принадлежать это расписание.
name Обязательно	str Имя расписания.
pipeline_id Обязательно	str Идентификатор конвейера, который будет отправляться по расписанию.
experiment_name Обязательно	str Имя эксперимента, для которого расписание будет отправлять выполнения.
recurrence	ScheduleRecurrence Повторение расписания для конвейера. значение по умолчанию: None
description	str Описание расписания. значение по умолчанию: None
pipeline_parameters	dict Словарь параметров для назначения новых значений {имя параметра, значение параметра}. значение по умолчанию: None
wait_for_provisioning	bool Следует ли ожидать завершения подготовки расписания. значение по умолчанию: False
wait_timeout	int Количество секунд перед истечением времени ожидания. значение по умолчанию: 3600
datastore	AzureBlobDatastore Хранилище данных для отслеживания появления измененных или добавленных BLOB-объектов. Примечание. Хранилища данных виртуальной сети не поддерживаются. Не может использоваться с повторением. значение по умолчанию: None
polling_interval	int Время в минутах между опросами измененных или добавленных больших двоичных объектов. Значение по умолчанию — 5 минут. Поддерживается только для расписаний хранилища данных. значение по умолчанию: 5
data_path_parameter_name	str Имя параметра конвейера пути к данным для задания, которому необходимо присвоить измененный путь к большому двоичному объекту. Поддерживается только для расписаний хранилища данных. значение по умолчанию: None
continue_on_step_failure	bool Следует ли продолжать выполнение других шагов в отправленном PipelineRun, если шаг завершается ошибкой. Если значение предоставлено, оно переопределит параметр continue_on_step_failure для конвейера. значение по умолчанию: None
path_on_datastore	str Необязательный элемент. Путь в хранилище данных для отслеживания измененных или добавленных больших двоичных объектов. Примечание. path_on_datastore будет указывать на хранилище данных, размещенное в контейнере, поэтому фактический путь, отслеживаемый расписанием, будет выглядеть так: “контейнер/путь_к_хранилищу_данных”. В противном случае отслеживается контейнер хранилища данных. Добавления и изменения, внесенные в папку, вложенную по отношению к path_on_datastore, не отслеживаются. Поддерживается только для расписаний хранилища данных. значение по умолчанию: None
_workflow_provider	<xref:azureml.pipeline.core._aeva_provider._AevaWorkflowProvider> Поставщик рабочего процесса. значение по умолчанию: None
_service_endpoint	str Конечная точка службы. значение по умолчанию: None

Возвращаемое значение

Тип	Описание
Schedule	Созданное расписание.

create_for_pipeline_endpoint

Создание расписания для конечной точки конвейера.

static create_for_pipeline_endpoint(workspace, name, pipeline_endpoint_id, experiment_name, recurrence=None, description=None, pipeline_parameters=None, wait_for_provisioning=False, wait_timeout=3600, datastore=None, polling_interval=5, data_path_parameter_name=None, continue_on_step_failure=None, path_on_datastore=None, _workflow_provider=None, _service_endpoint=None)

Параметры

Имя	Описание
workspace Обязательно	Workspace Объект рабочей области, которому будет принадлежать это расписание.
name Обязательно	str Имя расписания.
pipeline_endpoint_id Обязательно	str Идентификатор конечной точки конвейера, который будет отправляться по расписанию.
experiment_name Обязательно	str Имя эксперимента, для которого расписание будет отправлять выполнения.
recurrence	ScheduleRecurrence Повторение расписания для конвейера. значение по умолчанию: None
description	str Описание расписания. значение по умолчанию: None
pipeline_parameters	dict Словарь параметров для назначения новых значений {имя параметра, значение параметра}. значение по умолчанию: None
wait_for_provisioning	bool Следует ли ожидать завершения подготовки расписания. значение по умолчанию: False
wait_timeout	int Количество секунд перед истечением времени ожидания. значение по умолчанию: 3600
datastore	AzureBlobDatastore Хранилище данных для отслеживания появления измененных или добавленных BLOB-объектов. Примечание. Хранилища данных виртуальной сети не поддерживаются. Не может использоваться с повторением. значение по умолчанию: None
polling_interval	int Время в минутах между опросами измененных или добавленных больших двоичных объектов. Значение по умолчанию — 5 минут. Поддерживается только для расписаний хранилища данных. значение по умолчанию: 5
data_path_parameter_name	str Имя параметра конвейера пути к данным для задания, которому необходимо присвоить измененный путь к большому двоичному объекту. Поддерживается только для расписаний хранилища данных. значение по умолчанию: None
continue_on_step_failure	bool Следует ли продолжать выполнение других шагов в отправленном PipelineRun, если шаг завершается ошибкой. Если значение предоставлено, оно переопределит параметр continue_on_step_failure для конвейера. значение по умолчанию: None
path_on_datastore	str Необязательный элемент. Путь в хранилище данных для отслеживания измененных или добавленных больших двоичных объектов. Примечание. path_on_datastore будет указывать на хранилище данных, размещенное в контейнере, поэтому фактический путь, отслеживаемый расписанием, будет выглядеть так: “контейнер/путь_к_хранилищу_данных”. В противном случае отслеживается контейнер хранилища данных. Добавления и изменения, внесенные в папку, вложенную по отношению к path_on_datastore, не отслеживаются. Поддерживается только для расписаний хранилища данных. значение по умолчанию: None
_workflow_provider	<xref:azureml.pipeline.core._aeva_provider._AevaWorkflowProvider> Поставщик рабочего процесса. значение по умолчанию: None
_service_endpoint	str Конечная точка службы. значение по умолчанию: None

Возвращаемое значение

Тип	Описание
Schedule	Созданное расписание.

disable

Установка значения Disabled для расписания, в результате чего оно становится недоступным для выполнения.

disable(wait_for_provisioning=False, wait_timeout=3600)

Параметры

Имя	Описание
wait_for_provisioning	bool Следует ли ожидать завершения подготовки расписания. значение по умолчанию: False
wait_timeout	int Количество секунд перед истечением времени ожидания. значение по умолчанию: 3600

enable

Установка значения Active для расписания, в результате чего оно становится доступным для выполнения.

enable(wait_for_provisioning=False, wait_timeout=3600)

Параметры

Имя	Описание
wait_for_provisioning	bool Следует ли ожидать завершения подготовки расписания. значение по умолчанию: False
wait_timeout	int Количество секунд перед истечением времени ожидания. значение по умолчанию: 3600

get

Получение расписания с заданным идентификатором.

static get(workspace, id, _workflow_provider=None, _service_endpoint=None)

Параметры

Имя	Описание
workspace Обязательно	Workspace Рабочая область, в которой было создано расписание.
id Обязательно	str Идентификатор расписания.
_workflow_provider	<xref:azureml.pipeline.core._aeva_provider._AevaWorkflowProvider> Поставщик рабочего процесса. значение по умолчанию: None
_service_endpoint	str Конечная точка службы. значение по умолчанию: None

Возвращаемое значение

Тип	Описание
Schedule	Объект schedule

get_all

Получение всех расписаний в текущей рабочей области.

НЕ РЕКОМЕНДУЕТСЯ. Этот метод является устаревшим. Используйте вместо него метод list.

static get_all(workspace, active_only=True, pipeline_id=None, pipeline_endpoint_id=None, _workflow_provider=None, _service_endpoint=None)

Параметры

Имя	Описание
workspace Обязательно	Workspace Рабочая область.
active_only	bool Если задано значение True, возвращаются только те расписания, которые активны в данный момент. Применяется только в том случае, если не указан идентификатор конвейера. значение по умолчанию: True
pipeline_id	str Если значение задано, возвращаются только расписания для конвейера с заданным идентификатором. значение по умолчанию: None
pipeline_endpoint_id	str Если значение задано, возвращаются только расписания для конечной точки конвейера с заданным идентификатором. значение по умолчанию: None
_workflow_provider	<xref:azureml.pipeline.core._aeva_provider._AevaWorkflowProvider> Поставщик рабочего процесса. значение по умолчанию: None
_service_endpoint	str Конечная точка службы. значение по умолчанию: None

Возвращаемое значение

Тип	Описание
list	Список Schedule.

get_last_pipeline_run

Получение последнего выполнения конвейера, отправленного по расписанию. Возвращает значение None, если выполнения не отправлялись.

get_last_pipeline_run()

Возвращаемое значение

Тип	Описание
PipelineRun	Последнее выполнение конвейера.

get_pipeline_runs

Получение выполнений конвейера, созданных на основе расписания.

get_pipeline_runs()

Возвращаемое значение

Тип	Описание
list	Список PipelineRun.

get_schedules_for_pipeline_endpoint_id

Получение всех расписаний для заданного идентификатора конечной точки конвейера.

static get_schedules_for_pipeline_endpoint_id(workspace, pipeline_endpoint_id, _workflow_provider=None, _service_endpoint=None)

Параметры

Имя	Описание
workspace Обязательно	Workspace Рабочая область.
pipeline_endpoint_id Обязательно	str Идентификатор конечной точки конвейера.
_workflow_provider	<xref:azureml.pipeline.core._aeva_provider._AevaWorkflowProvider> Поставщик рабочего процесса. значение по умолчанию: None
_service_endpoint	str Конечная точка службы. значение по умолчанию: None

Возвращаемое значение

Тип	Описание
list	Список Schedule.

get_schedules_for_pipeline_id

Получение всех расписаний для заданного идентификатора конвейера.

static get_schedules_for_pipeline_id(workspace, pipeline_id, _workflow_provider=None, _service_endpoint=None)

Параметры

Имя	Описание
workspace Обязательно	Workspace Рабочая область.
pipeline_id Обязательно	str Идентификатор конвейера.
_workflow_provider	<xref:azureml.pipeline.core._aeva_provider._AevaWorkflowProvider> Поставщик рабочего процесса. значение по умолчанию: None
_service_endpoint	str Конечная точка службы. значение по умолчанию: None

Возвращаемое значение

Тип	Описание
list	Список Schedule.

list

Получение всех расписаний в текущей рабочей области.

static list(workspace, active_only=True, pipeline_id=None, pipeline_endpoint_id=None, _workflow_provider=None, _service_endpoint=None)

Параметры

Имя	Описание
workspace Обязательно	Workspace Рабочая область.
active_only	bool Если задано значение True, возвращаются только те расписания, которые активны в данный момент. Применяется только в том случае, если не указан идентификатор конвейера. значение по умолчанию: True
pipeline_id	str Если значение задано, возвращаются только расписания для конвейера с заданным идентификатором. значение по умолчанию: None
pipeline_endpoint_id	str Если значение задано, возвращаются только расписания для конечной точки конвейера с заданным идентификатором. значение по умолчанию: None
_workflow_provider	<xref:azureml.pipeline.core._aeva_provider._AevaWorkflowProvider> Поставщик рабочего процесса. значение по умолчанию: None
_service_endpoint	str Конечная точка службы. значение по умолчанию: None

Возвращаемое значение

Тип	Описание
list	Список Schedule.

load_yaml

Загрузка и чтение файла YAML для получения параметров расписания.

Файл YAML — это еще один способ передачи параметров расписания для создания расписания.

static load_yaml(workspace, filename, _workflow_provider=None, _service_endpoint=None)

Параметры

Имя	Описание
workspace Обязательно	Workspace Рабочая область.
filename Обязательно	str Имя файла YAML с расположением.
_workflow_provider	<xref:azureml.pipeline.core._aeva_provider._AevaWorkflowProvider> Поставщик рабочего процесса. значение по умолчанию: None
_service_endpoint	str Конечная точка службы. значение по умолчанию: None

Возвращаемое значение

Тип	Описание
dict	Словарь параметров и значений Schedule.

Для расписаний поддерживаются два типа файлов YAML. Первый считывает и загружает сведения о повторении, чтобы создать расписание для запуска конвейера. Второй считывает и загружает сведения о хранилище данных, чтобы создать расписание для запуска конвейера.

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


   from azureml.pipeline.core import Schedule

   schedule_info = Schedule.load_yaml(workspace=workspace,
                                      filename='./yaml/test_schedule_with_recurrence.yaml')
   schedule = Schedule.create(workspace, name="TestSchedule", pipeline_id="pipeline_id",
                              experiment_name="helloworld", recurrence=schedule_info.get("recurrence"),
                              description=schedule_info.get("description"))

Пример файла YAML test_schedule_with_recurrence.yaml:


   Schedule:
       description: "Test create with recurrence"
       recurrence:
           frequency: Week # Can be "Minute", "Hour", "Day", "Week", or "Month".
           interval: 1 # how often fires
           start_time: 2019-06-07T10:50:00
           time_zone: UTC
           hours:
           - 1
           minutes:
           - 0
           time_of_day: null
           week_days:
           - Friday
       pipeline_parameters: {'a':1}
       wait_for_provisioning: True
       wait_timeout: 3600
       datastore_name: ~
       polling_interval: ~
       data_path_parameter_name: ~
       continue_on_step_failure: None
       path_on_datastore: ~

Пример создания расписания, которое будет отправлять конвейер в хранилище данных:


   from azureml.pipeline.core import Schedule

   schedule_info = Schedule.load_yaml(workspace=workspace,
                                      filename='./yaml/test_schedule_with_datastore.yaml')
   schedule = Schedule.create(workspace, name="TestSchedule", pipeline_id="pipeline_id",
                              experiment_name="helloworld",datastore=schedule_info.get("datastore_name"),
                              polling_interval=schedule_info.get("polling_interval"),
                              data_path_parameter_name=schedule_info.get("data_path_parameter_name"),
                              continue_on_step_failure=schedule_info.get("continue_on_step_failure"),
                              path_on_datastore=schedule_info.get("path_on_datastore"))

update

Обновление расписания.

update(name=None, description=None, recurrence=None, pipeline_parameters=None, status=None, wait_for_provisioning=False, wait_timeout=3600, datastore=None, polling_interval=None, data_path_parameter_name=None, continue_on_step_failure=None, path_on_datastore=None)

Параметры

Имя	Описание
name	str Новое имя расписания. значение по умолчанию: None
recurrence	ScheduleRecurrence Новое повторение расписания для конвейера. значение по умолчанию: None
description	str Новое описание расписания. значение по умолчанию: None
pipeline_parameters	dict Словарь параметров для назначения новых значений {имя параметра, значение параметра}. значение по умолчанию: None
status	str Новое состояние расписания: Active или Disabled. значение по умолчанию: None
wait_for_provisioning	bool Следует ли ожидать завершения подготовки расписания. значение по умолчанию: False
wait_timeout	int Количество секунд перед истечением времени ожидания. значение по умолчанию: 3600
datastore	AzureBlobDatastore Хранилище данных для отслеживания появления измененных или добавленных BLOB-объектов. Примечание. Хранилища данных виртуальной сети не поддерживаются. значение по умолчанию: None
polling_interval	int Время в минутах между опросами измененных или добавленных больших двоичных объектов. Значение по умолчанию — 5 минут. значение по умолчанию: None
data_path_parameter_name	str Имя параметра конвейера пути к данным для задания, которому необходимо присвоить измененный путь к большому двоичному объекту. значение по умолчанию: None
continue_on_step_failure	bool Следует ли продолжать выполнение других шагов в отправленном PipelineRun, если шаг завершается ошибкой. Если значение предоставлено, оно переопределит параметр continue_on_step_failure для конвейера. значение по умолчанию: None
path_on_datastore	str Необязательный элемент. Путь в хранилище данных для отслеживания измененных или добавленных больших двоичных объектов. Примечание. path_on_datastore будет указывать на хранилище данных, размещенное в контейнере, поэтому фактический путь, отслеживаемый расписанием, будет выглядеть так: “контейнер/путь_к_хранилищу_данных”. В противном случае отслеживается контейнер хранилища данных. Добавления и изменения, внесенные в папку, вложенную по отношению к path_on_datastore, не отслеживаются. Поддерживается только для расписаний хранилища данных. значение по умолчанию: None

Атрибуты

continue_on_step_failure

Получение значения параметра continue_on_step_failure.

Возвращаемое значение

Тип	Описание
bool	Значение параметра `continue_on_step_failure`.

data_path_parameter_name

Получение имени параметра пути к данным для конвейера для задания измененного пути к BLOB-объекту.

Возвращаемое значение

Тип	Описание
str	Имя параметра пути к данным.

datastore_name

Получение имени хранилища данных, используемого для расписания.

Возвращаемое значение

Тип	Описание
str	Имя хранилища данных.

description

Получение описания расписания.

Возвращаемое значение

Тип	Описание
str	Описание расписания.

id

Получение идентификатора расписания.

Возвращаемое значение

Тип	Описание
str	Идентификатор.

name

Получение имени расписания.

Возвращаемое значение

Тип	Описание
str	Имя.

path_on_datastore

Получение пути к хранилищу данных, которое отслеживается расписанием.

Возвращаемое значение

Тип	Описание
str	Путь к хранилищу данных.

pipeline_endpoint_id

Получение идентификатора конечной точки конвейера, отправляемого по расписанию.

Возвращаемое значение

Тип	Описание
str	Идентификатор.

pipeline_id

Получение идентификатора конвейера, отправляемого по расписанию.

Возвращаемое значение

Тип	Описание
str	Идентификатор.

polling_interval

Получение интервала в минутах между опросами на наличие измененных или добавленных BLOB-объектов.

Возвращаемое значение

Тип	Описание
int	Интервал опроса.

recurrence

Получение повторения расписания.

Возвращаемое значение

Тип	Описание
ScheduleRecurrence	Повторение расписания.

status

Получение состояния расписания.

Возвращаемое значение

Тип	Описание
str	Состояние расписания.

Share via

Schedule Класс

Конструктор

Параметры

Комментарии

Методы

create

Параметры

Возвращаемое значение

create_for_pipeline_endpoint

Параметры

Возвращаемое значение

disable

Параметры

enable

Параметры

get

Параметры

Возвращаемое значение

get_all

Параметры

Возвращаемое значение

get_last_pipeline_run

Возвращаемое значение

get_pipeline_runs

Возвращаемое значение

get_schedules_for_pipeline_endpoint_id

Параметры

Возвращаемое значение

get_schedules_for_pipeline_id

Параметры

Возвращаемое значение

list

Параметры

Возвращаемое значение

load_yaml

Параметры

Возвращаемое значение

Комментарии

update

Параметры

Атрибуты

continue_on_step_failure

Возвращаемое значение

data_path_parameter_name

Возвращаемое значение

datastore_name

Возвращаемое значение

description

Возвращаемое значение

id

Возвращаемое значение

name

Возвращаемое значение

path_on_datastore

Возвращаемое значение

pipeline_endpoint_id

Возвращаемое значение

pipeline_id

Возвращаемое значение

polling_interval

Возвращаемое значение

recurrence

Возвращаемое значение

status

Возвращаемое значение

Обратная связь

Обратная связь

Дополнительные ресурсы