Публикация конвейера пакетного вывода

Завершено

Конвейер пакетного вывода можно опубликовать в качестве службы REST, как показано в следующем примере кода.

published_pipeline = pipeline_run.publish_pipeline(name='Batch_Prediction_Pipeline',
                                                   description='Batch pipeline',
                                                   version='1.0')
rest_endpoint = published_pipeline.endpoint

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

import requests

response = requests.post(rest_endpoint,
                         headers=auth_header,
                         json={"ExperimentName": "Batch_Prediction"})
run_id = response.json()["Id"]

Можно также запланировать автоматический запуск опубликованного конвейера, как показано в следующем примере кода.

from azureml.pipeline.core import ScheduleRecurrence, Schedule

weekly = ScheduleRecurrence(frequency='Week', interval=1)
pipeline_schedule = Schedule.create(ws, name='Weekly Predictions',
                                        description='batch inferencing',
                                        pipeline_id=published_pipeline.id,
                                        experiment_name='Batch_Prediction',
                                        recurrence=weekly)