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>

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

Default value: 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

Идентификатор конечной точки конвейера, который будет отправляться по расписанию.

Default value: 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 не задан) не обнаруживается.

Кроме того, если конвейер был создан, чтобы использовать DataPathPipelineParameter для описания входных данных этапа, задействуйте параметр 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

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

Default value: None
description
str

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

Default value: None
pipeline_parameters
dict

Словарь параметров для назначения новых значений {имя параметра, значение параметра}.

Default value: None
wait_for_provisioning
bool

Следует ли ожидать завершения подготовки расписания.

Default value: False
wait_timeout
int

Количество секунд перед истечением времени ожидания.

Default value: 3600
datastore
AzureBlobDatastore

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

Default value: None
polling_interval
int

Время в минутах между опросами измененных или добавленных больших двоичных объектов. Значение по умолчанию — 5 минут. Поддерживается только для расписаний хранилища данных.

Default value: 5
data_path_parameter_name
str

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

Default value: None
continue_on_step_failure
bool

Следует ли продолжать выполнение других шагов в отправленном PipelineRun, если шаг завершается ошибкой. Если значение предоставлено, оно переопределит параметр continue_on_step_failure для конвейера.

Default value: None
path_on_datastore
str

Необязательный элемент. Путь в хранилище данных для отслеживания измененных или добавленных больших двоичных объектов. Примечание. path_on_datastore будет указывать на хранилище данных, размещенное в контейнере, поэтому фактический путь, отслеживаемый расписанием, будет выглядеть так: “контейнер/путь_к_хранилищу_данных”. В противном случае отслеживается контейнер хранилища данных. Добавления и изменения, внесенные в папку, вложенную по отношению к path_on_datastore, не отслеживаются. Поддерживается только для расписаний хранилища данных.

Default value: None
_workflow_provider
<xref:azureml.pipeline.core._aeva_provider._AevaWorkflowProvider>

Поставщик рабочего процесса.

Default value: None
_service_endpoint
str

Конечная точка службы.

Default value: None

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

Тип Описание
Schedule

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

create_for_pipeline_endpoint

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

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

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

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

Default value: None
description
str

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

Default value: None
pipeline_parameters
dict

Словарь параметров для назначения новых значений {имя параметра, значение параметра}.

Default value: None
wait_for_provisioning
bool

Следует ли ожидать завершения подготовки расписания.

Default value: False
wait_timeout
int

Количество секунд перед истечением времени ожидания.

Default value: 3600
datastore
AzureBlobDatastore

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

Default value: None
polling_interval
int

Время в минутах между опросами измененных или добавленных больших двоичных объектов. Значение по умолчанию — 5 минут. Поддерживается только для расписаний хранилища данных.

Default value: 5
data_path_parameter_name
str

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

Default value: None
continue_on_step_failure
bool

Следует ли продолжать выполнение других шагов в отправленном PipelineRun, если шаг завершается ошибкой. Если значение предоставлено, оно переопределит параметр continue_on_step_failure для конвейера.

Default value: None
path_on_datastore
str

Необязательный элемент. Путь в хранилище данных для отслеживания измененных или добавленных больших двоичных объектов. Примечание. path_on_datastore будет указывать на хранилище данных, размещенное в контейнере, поэтому фактический путь, отслеживаемый расписанием, будет выглядеть так: “контейнер/путь_к_хранилищу_данных”. В противном случае отслеживается контейнер хранилища данных. Добавления и изменения, внесенные в папку, вложенную по отношению к path_on_datastore, не отслеживаются. Поддерживается только для расписаний хранилища данных.

Default value: None
_workflow_provider
<xref:azureml.pipeline.core._aeva_provider._AevaWorkflowProvider>

Поставщик рабочего процесса.

Default value: None
_service_endpoint
str

Конечная точка службы.

Default value: None

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

Тип Описание
Schedule

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

disable

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

disable(wait_for_provisioning=False, wait_timeout=3600)

Параметры

Имя Описание
wait_for_provisioning
bool

Следует ли ожидать завершения подготовки расписания.

Default value: False
wait_timeout
int

Количество секунд перед истечением времени ожидания.

Default value: 3600

enable

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

enable(wait_for_provisioning=False, wait_timeout=3600)

Параметры

Имя Описание
wait_for_provisioning
bool

Следует ли ожидать завершения подготовки расписания.

Default value: False
wait_timeout
int

Количество секунд перед истечением времени ожидания.

Default value: 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>

Поставщик рабочего процесса.

Default value: None
_service_endpoint
str

Конечная точка службы.

Default value: 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, возвращаются только те расписания, которые активны в данный момент. Применяется только в том случае, если не указан идентификатор конвейера.

Default value: True
pipeline_id
str

Если значение задано, возвращаются только расписания для конвейера с заданным идентификатором.

Default value: None
pipeline_endpoint_id
str

Если значение задано, возвращаются только расписания для конечной точки конвейера с заданным идентификатором.

Default value: None
_workflow_provider
<xref:azureml.pipeline.core._aeva_provider._AevaWorkflowProvider>

Поставщик рабочего процесса.

Default value: None
_service_endpoint
str

Конечная точка службы.

Default value: 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>

Поставщик рабочего процесса.

Default value: None
_service_endpoint
str

Конечная точка службы.

Default value: 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>

Поставщик рабочего процесса.

Default value: None
_service_endpoint
str

Конечная точка службы.

Default value: 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, возвращаются только те расписания, которые активны в данный момент. Применяется только в том случае, если не указан идентификатор конвейера.

Default value: True
pipeline_id
str

Если значение задано, возвращаются только расписания для конвейера с заданным идентификатором.

Default value: None
pipeline_endpoint_id
str

Если значение задано, возвращаются только расписания для конечной точки конвейера с заданным идентификатором.

Default value: None
_workflow_provider
<xref:azureml.pipeline.core._aeva_provider._AevaWorkflowProvider>

Поставщик рабочего процесса.

Default value: None
_service_endpoint
str

Конечная точка службы.

Default value: 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>

Поставщик рабочего процесса.

Default value: None
_service_endpoint
str

Конечная точка службы.

Default value: 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

Новое имя расписания.

Default value: None
recurrence
ScheduleRecurrence

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

Default value: None
description
str

Новое описание расписания.

Default value: None
pipeline_parameters
dict

Словарь параметров для назначения новых значений {имя параметра, значение параметра}.

Default value: None
status
str

Новое состояние расписания: Active или Disabled.

Default value: None
wait_for_provisioning
bool

Следует ли ожидать завершения подготовки расписания.

Default value: False
wait_timeout
int

Количество секунд перед истечением времени ожидания.

Default value: 3600
datastore
AzureBlobDatastore

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

Default value: None
polling_interval
int

Время в минутах между опросами измененных или добавленных больших двоичных объектов. Значение по умолчанию — 5 минут.

Default value: None
data_path_parameter_name
str

Имя параметра конвейера пути к данным для задания, которому необходимо присвоить измененный путь к большому двоичному объекту.

Default value: None
continue_on_step_failure
bool

Следует ли продолжать выполнение других шагов в отправленном PipelineRun, если шаг завершается ошибкой. Если значение предоставлено, оно переопределит параметр continue_on_step_failure для конвейера.

Default value: None
path_on_datastore
str

Необязательный элемент. Путь в хранилище данных для отслеживания измененных или добавленных больших двоичных объектов. Примечание. path_on_datastore будет указывать на хранилище данных, размещенное в контейнере, поэтому фактический путь, отслеживаемый расписанием, будет выглядеть так: “контейнер/путь_к_хранилищу_данных”. В противном случае отслеживается контейнер хранилища данных. Добавления и изменения, внесенные в папку, вложенную по отношению к path_on_datastore, не отслеживаются. Поддерживается только для расписаний хранилища данных.

Default value: 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

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