PipelineEndpoint Clase

Representa un Pipeline flujo de trabajo que se puede desencadenar desde una dirección URL de punto de conexión única.

PipelineEndpoints se puede usar para crear nuevas versiones de un PublishedPipeline mientras se mantiene el mismo punto de conexión. PipelineEndpoints se denominan de forma única dentro de un área de trabajo.

Con el atributo endpoint de un objeto PipelineEndpoint, puede desencadenar nuevas ejecuciones de canalización desde aplicaciones externas con llamadas REST. Para obtener información sobre cómo autenticarse al llamar a puntos de conexión REST, consulte https://aka.ms/pl-restep-auth.

Para más información sobre cómo crear y ejecutar canalizaciones de aprendizaje automático, consulte https://aka.ms/pl-first-pipeline.

Inicializar PipelineEndpoint.

Constructor

PipelineEndpoint(workspace, id, name, description, status, default_version, endpoint, pipeline_version_list, _pipeline_endpoint_provider=None, _published_pipeline_provider=None, _swaggerurl=None)

Parámetros

Nombre	Description
workspace Requerido	Workspace Área de trabajo en la que se define PipelineEndpoint.
id Requerido	str Identificador de PipelineEndpoint.
name Requerido	str Nombre de PipelineEndpoint.
description Requerido	str Descripción de PipelineEndpoint.
status Requerido	str El nuevo estado de PipelineEndpoint: "Activo" o "Deshabilitado".
default_version Requerido	str La versión predeterminada de la canalización en PipelineEndpoint, incrementos automáticos, comienza con "0".
endpoint Requerido	str La dirección URL del punto de conexión de REST para PipelineEndpoint, que se puede usar para enviar ejecuciones de canalización.
pipeline_version_list Requerido	list Lista de PipelineIdVersion objetos.
_pipeline_endpoint_provider Requerido	<xref:azureml.pipeline.core._aeva_provider._AevaPublishedPipelineProvider> Proveedor PipelineEndpoint.
_pipeline_endpoint_provider Requerido	El proveedor PublishedPipeline.
workspace Requerido	Workspace El objeto de área de trabajo al que pertenece este PipelineEndpoint.
id Requerido	str Identificador de PipelineEndpoint.
name Requerido	str Nombre de PipelineEndpoint.
description Requerido	str Descripción de PipelineEndpoint.
status Requerido	str El nuevo estado de PipelineEndpoint: "Activo" o "Deshabilitado".
default_version Requerido	str La versión predeterminada de la canalización en PipelineEndpoint, incrementos automáticos, comienza con "0"
endpoint Requerido	str Dirección URL del punto de conexión de REST para PipelineEndpoint para enviar ejecuciones de canalización.
pipeline_version_list Requerido	list Lista de PipelineIdVersion
_pipeline_endpoint_provider Requerido	<xref:azureml.pipeline.core._aeva_provider._AevaPublishedPipelineProvider> Proveedor PipelineEndpoint.
_pipeline_endpoint_provider Requerido	El proveedor PublishedPipeline.
swaggerendpoint Requerido	Dirección URL del punto de conexión de REST de Swagger para PipelineEndpoint para enviar ejecuciones de canalización.

Comentarios

Se puede crear un objeto PipelineEndpoint a partir de o Pipeline .PublishedPipeline

Un ejemplo para publicar desde una canalización o PublishedPipeline es el siguiente:


   from azureml.pipeline.core import PipelineEndpoint

   # The pipeline argument can be either a Pipeline or a PublishedPipeline
   pipeline_endpoint = PipelineEndpoint.publish(workspace=ws,
                                                name="PipelineEndpointName",
                                                pipeline=pipeline,
                                                description="New Pipeline Endpoint")

Envíe un punto de conexión de canalización mediante submit. Cuando se llama a submit, se crea un PipelineRun objeto que, a su vez, crea StepRun objetos para cada paso del flujo de trabajo.

Un ejemplo de cómo enviar un pipelineEndpoint es el siguiente:


   from azureml.pipeline.core import PipelineEndpoint

   pipeline_endpoint = PipelineEndpoint.get(workspace=ws, name="PipelineEndpointName")
   pipeline_run = experiment.submit(pipeline_endpoint)

Hay una serie de opciones opcionales que se pueden especificar al enviar un pipelineEndpoint. Estos incluyen:

pipeline_parameters: parámetros para la ejecución de la canalización, diccionario de {name: value}. Consulte PipelineParameter para obtener más detalles.
parent_run_id: puede proporcionar un identificador de ejecución para establecer la ejecución primaria de esta ejecución de canalización, que se refleja en RunHistory. La ejecución primaria debe pertenecer al mismo experimento al que se envía esta canalización.
pipeline_version: la versión de canalización que se va a ejecutar.

Un ejemplo para enviar un pipelineEndpoint mediante esta configuración es el siguiente:


   from azureml.pipeline.core import PipelineEndpoint

   pipeline_endpoint = PipelineEndpoint.get(workspace=ws, name="PipelineEndpointName")
   pipeline_run = experiment.submit(pipeline_endpoint,
                                    pipeline_parameters={"param1": "value1"},
                                    parent_run_id="<run_id>",
                                    pipeline_version="0")

Para agregar una nueva versión de pipelineEndpoint, use:


   from azureml.pipeline.core import PipelineEndpoint

   pipeline_endpoint = PipelineEndpoint.get(workspace=ws, name="PipelineEndpointName")
   pipeline_endpoint.add(published_pipeline)

Consulte el cuaderno siguiente para obtener información adicional sobre cómo crear y usar PipelineEndpoints: https://aka.ms/pl-ver-endpoint.

Métodos

add	Agregue la canalización especificada a PipelineEndpoint.
add_default	Agregue la canalización especificada a PipelineEndpoint y establezca la versión predeterminada en la versión de canalización agregada.
archive	Archivar PipelineEndpoint.
disable	Establezca PipelineEndpoint en "Disabled" (Deshabilitado) y no esté disponible para ejecutarse.
enable	Establezca PipelineEndpoint en "Active" y esté disponible para ejecutarse.
get	Obtiene pipelineEndpoint por nombre o identificador, produce una excepción si no se proporciona.
get_all	Obtenga todos los puntos de conexión activos de PipelineEndpoints en el área de trabajo actual. Obtenga todos los puntos de conexión de PipelineEndpoint activos. NOTA: Este método está en desuso en favor de PipelineEndpoint.list().
get_all_pipelines	Obtenga la lista de canalizaciones en PipelineEndpoint. NOTA: Este método está en desuso a favor de list_pipelines()
get_all_versions	Obtenga la lista de canalizaciones y las versiones correspondientes en PipelineEndpoint. NOTA: Este método está en desuso en favor de list_versions()
get_default_version	Obtenga la versión predeterminada de PipelineEndpoint.
get_pipeline	Obtiene la canalización de una versión especificada o el valor predeterminado; produce una excepción si no se encuentra la versión.
list	Enumere los puntos de conexión activos en el área de trabajo actual.
list_pipelines	Obtenga una lista de canalizaciones asociadas con PipelineEndpoint.
list_versions	Obtenga una lista de canalizaciones y las versiones correspondientes de PipelineEndpoint.
publish	Cree un pipelineEndpoint con el nombre especificado y la canalización o canalización publicada. El punto de conexión de canalización es una API REST que se puede usar desde aplicaciones externas. Para obtener información sobre cómo autenticarse al llamar a puntos de conexión REST, consulte https://aka.ms/pl-restep-auth. Para obtener más información sobre cómo trabajar con puntos de conexión de canalización, consulte https://aka.ms/pl-first-pipeline. Produce excepción si ya existe un pipelineEndpoint con el nombre especificado.
reactivate	Reactivar un pipelineEndpoint que se ha archivado.
set_default	Establezca la versión predeterminada de PipelineEndpoint; produce una excepción si no se encuentra la canalización especificada.
set_default_version	Establezca la versión predeterminada de PipelineEndpoint; produce una excepción si no se encuentra la versión especificada.
set_name	Establezca el nombre de PipelineEndpoint.
submit	Enviar un experimento de canalización de una versión determinada; si la versión no desencadena ninguna versión predeterminada de la canalización.

add

Agregue la canalización especificada a PipelineEndpoint.

add(pipeline)

Parámetros

Nombre	Description
pipeline Requerido	PublishedPipeline Una canalización publicada que se va a agregar.

add_default

Agregue la canalización especificada a PipelineEndpoint y establezca la versión predeterminada en la versión de canalización agregada.

add_default(pipeline)

Parámetros

Nombre	Description
pipeline Requerido	PublishedPipeline Una canalización publicada que se va a agregar como versión predeterminada.

disable

Establezca PipelineEndpoint en "Disabled" (Deshabilitado) y no esté disponible para ejecutarse.

disable()

enable

Establezca PipelineEndpoint en "Active" y esté disponible para ejecutarse.

enable()

get

Obtiene pipelineEndpoint por nombre o identificador, produce una excepción si no se proporciona.

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

Parámetros

Nombre	Description
workspace Requerido	Workspace Área de trabajo en la que se creó PipelineEndpoint.
id	str Identificador de PipelineEndpoint. Valor predeterminado: None
name	str Nombre de PipelineEndpoint. Valor predeterminado: None
_workflow_provider	<xref:azureml.pipeline.core._aeva_provider._AevaWorkflowProvider> Proveedor de flujo de trabajo. Valor predeterminado: None
_service_endpoint	str Punto de conexión de servicio. Valor predeterminado: None

Devoluciones

Tipo	Description
PipelineEndpoint	Objeto PipelineEndpoint.

get_all

Obtenga todos los puntos de conexión activos de PipelineEndpoints en el área de trabajo actual.

Obtenga todos los puntos de conexión de PipelineEndpoint activos. NOTA: Este método está en desuso en favor de PipelineEndpoint.list().

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

Parámetros

Nombre	Description
workspace Requerido	Workspace Área de trabajo.
active_only	bool Si es true, solo devuelve PipelineEndpoints que están activos actualmente. Valor predeterminado: True
_workflow_provider	<xref:azureml.pipeline.core._aeva_provider._AevaWorkflowProvider> Proveedor de flujo de trabajo. Valor predeterminado: None
_service_endpoint	str Punto de conexión de servicio. Valor predeterminado: None

Devoluciones

Tipo	Description
list	Lista de PipelineEndpoint objetos.

get_all_pipelines

Obtenga la lista de canalizaciones en PipelineEndpoint.

NOTA: Este método está en desuso a favor de list_pipelines()

get_all_pipelines(active_only=True, _workflow_provider=None, _service_endpoint=None)

Parámetros

Nombre	Description
active_only	bool Marca para devolver solo canalizaciones activas. Valor predeterminado: True
_workflow_provider	<xref:azureml.pipeline.core._aeva_provider._AevaWorkflowProvider> Proveedor de flujo de trabajo. Valor predeterminado: None
_service_endpoint	str Punto de conexión de servicio. Valor predeterminado: None

Devoluciones

Tipo	Description
list	Lista de PublishedPipeline objetos.

get_all_versions

Obtenga la lista de canalizaciones y las versiones correspondientes en PipelineEndpoint.

NOTA: Este método está en desuso en favor de list_versions()

get_all_versions(_workflow_provider=None, _service_endpoint=None)

Parámetros

Nombre	Description
_workflow_provider	<xref:azureml.pipeline.core._aeva_provider._AevaWorkflowProvider> Proveedor de flujo de trabajo. Valor predeterminado: None
_service_endpoint	str Punto de conexión de servicio. Valor predeterminado: None

Devoluciones

Tipo	Description
list	Lista de PipelineVersion objetos.

get_default_version

Obtenga la versión predeterminada de PipelineEndpoint.

get_default_version()

Devoluciones

Tipo	Description
str	Versión predeterminada del punto de conexión de canalización.

get_pipeline

Obtiene la canalización de una versión especificada o el valor predeterminado; produce una excepción si no se encuentra la versión.

get_pipeline(version=None)

Parámetros

Nombre	Description
version	str Versión de la canalización que se va a devolver. Valor predeterminado: None

Devoluciones

Tipo	Description
PublishedPipeline	Una canalización publicada.

list

Enumere los puntos de conexión activos en el área de trabajo actual.

static list(workspace, active_only=True, max_results=100, _workflow_provider=None, _service_endpoint=None)

Parámetros

Nombre	Description
workspace Requerido	Workspace Área de trabajo.
active_only	bool Si es true, solo devuelve PipelineEndpoints que están activos actualmente. Valor predeterminado: True
max_results	int max lines of returned PipelineEndpoints Valor predeterminado: 100
_workflow_provider	<xref:azureml.pipeline.core._aeva_provider._AevaWorkflowProvider> Proveedor de flujo de trabajo. Valor predeterminado: None
_service_endpoint	str Punto de conexión de servicio. Valor predeterminado: None

Devoluciones

Tipo	Description
list	Lista de PipelineEndpoint objetos.

list_pipelines

Obtenga una lista de canalizaciones asociadas con PipelineEndpoint.

list_pipelines(active_only=True, _workflow_provider=None, _service_endpoint=None)

Parámetros

Nombre	Description
active_only	bool Indica si se devuelven solo canalizaciones activas. Valor predeterminado: True
_workflow_provider	<xref:azureml.pipeline.core._aeva_provider._AevaWorkflowProvider> Proveedor de flujo de trabajo. Valor predeterminado: None
_service_endpoint	str Punto de conexión de servicio. Valor predeterminado: None

Devoluciones

Tipo	Description
list	Lista de PublishedPipeline objetos.

list_versions

Obtenga una lista de canalizaciones y las versiones correspondientes de PipelineEndpoint.

list_versions(_workflow_provider=None, _service_endpoint=None)

Parámetros

Nombre	Description
_workflow_provider	<xref:azureml.pipeline.core._aeva_provider._AevaWorkflowProvider> Proveedor de flujo de trabajo. Valor predeterminado: None
_service_endpoint	str Punto de conexión de servicio. Valor predeterminado: None

Devoluciones

Tipo	Description
list	Lista de PipelineVersion objetos.

publish

Cree un pipelineEndpoint con el nombre especificado y la canalización o canalización publicada.

El punto de conexión de canalización es una API REST que se puede usar desde aplicaciones externas. Para obtener información sobre cómo autenticarse al llamar a puntos de conexión REST, consulte https://aka.ms/pl-restep-auth.

Para obtener más información sobre cómo trabajar con puntos de conexión de canalización, consulte https://aka.ms/pl-first-pipeline.

Produce excepción si ya existe un pipelineEndpoint con el nombre especificado.

static publish(workspace, name, description, pipeline, _workflow_provider=None, _service_endpoint=None)

Parámetros

Nombre	Description
workspace Requerido	Workspace Área de trabajo en la que se va a crear PipelineEndpoint.
name Requerido	str Nombre de PipelineEndpoint.
description Requerido	str Descripción de PipelineEndpoint.
pipeline Requerido	PublishedPipeline o Pipeline Canalización o canalización publicada.
_service_endpoint	str Punto de conexión de servicio. Valor predeterminado: None
_workflow_provider	<xref:azureml.pipeline.core._aeva_provider._AevaWorkflowProvider> Proveedor de flujo de trabajo. Valor predeterminado: None

Devoluciones

Tipo	Description
PipelineEndpoint	Nuevo pipelineEndpoint.

Excepciones

Tipo	Description
ValueError

reactivate

Reactivar un pipelineEndpoint que se ha archivado.

reactivate(name)

Parámetros

Nombre	Description
name Requerido	str Nombre que se va a establecer.

Devoluciones

Tipo	Description
PipelineEndpoint	Objeto PipelineEndpoint.

set_default

Establezca la versión predeterminada de PipelineEndpoint; produce una excepción si no se encuentra la canalización especificada.

set_default(pipeline)

Parámetros

Nombre	Description
pipeline Requerido	PublishedPipeline Canalización publicada que se va a establecer como valor predeterminado.

Excepciones

Tipo	Description
ValueError

set_default_version

Establezca la versión predeterminada de PipelineEndpoint; produce una excepción si no se encuentra la versión especificada.

set_default_version(version)

Parámetros

Nombre	Description
version Requerido	str Versión que se va a establecer como la versión predeterminada en PipelineEndpoint.

Excepciones

Tipo	Description
ValueError

set_name

Establezca el nombre de PipelineEndpoint.

set_name(name)

Parámetros

Nombre	Description
name Requerido	str Nombre que se va a establecer.

submit

Enviar un experimento de canalización de una versión determinada; si la versión no desencadena ninguna versión predeterminada de la canalización.

submit(experiment_name, pipeline_parameters=None, parent_run_id=None, pipeline_version=None)

Parámetros

Nombre	Description
experiment_name Requerido	str Nombre del experimento en el que se va a enviar la canalización.
pipeline_parameters	dict Parámetros que se usarán en la ejecución de la canalización, pasados como diccionario de {name: value}. Consulte PipelineParameter para obtener más detalles. Valor predeterminado: None
parent_run_id	str Puede proporcionar un identificador de ejecución para establecer la ejecución primaria de esta ejecución de canalización, que se refleja en RunHistory. La ejecución primaria debe pertenecer al mismo experimento al que se envía esta canalización. Valor predeterminado: None
pipeline_version	str Versión de la canalización que se va a ejecutar. Valor predeterminado: None

Devoluciones

Tipo	Description
PipelineRun	La ejecución de la canalización enviada.

Excepciones

Tipo	Description
ValueError

Atributos

default_version

Obtenga la versión predeterminada de PipelineEndpoint.

Devoluciones

Tipo	Description
str	La versión predeterminada.

description

Obtenga la descripción de PipelineEndpoint.

Devoluciones

Tipo	Description
str	Descripción.

endpoint

Obtenga la dirección URL del punto de conexión de REST de PipelineEndpoint.

El punto de conexión se puede usar para desencadenar ejecuciones de la canalización.

Devoluciones

Tipo	Description
str	Punto de conexión REST para PipelineEndpoint para ejecutar la canalización.

id

Obtenga el identificador de PipelineEndpoint.

Devoluciones

Tipo	Description
str	Identificador de PipelineEndpoint.

name

Obtenga el nombre de PipelineEndpoint.

Devoluciones

Tipo	Description
str	Nombre.

pipeline_version_list

Obtenga la lista de versiones de canalización.

Devoluciones

Tipo	Description
list	Lista de PipelineIdVersion objetos.

status

Obtenga el estado de PipelineEndpoint.

Devoluciones

Tipo	Description
str	Estado.

swaggerurl

Obtenga la dirección URL de Swagger rest de PipelineEndpoint.

La dirección URL de Swagger puede ver el esquema del punto de conexión de canalización.

Devoluciones

Tipo	Description
str	REST Swagger para PipelineEndpoint para ejecutar la canalización.

Comentarios

¿Le ha resultado útil esta página?

Compartir a través de

PipelineEndpoint Clase

Constructor

Parámetros

Comentarios

Métodos

add

Parámetros

add_default

Parámetros

archive

disable

enable

get

Parámetros

Devoluciones

get_all

Parámetros

Devoluciones

get_all_pipelines

Parámetros

Devoluciones

get_all_versions

Parámetros

Devoluciones

get_default_version

Devoluciones

get_pipeline

Parámetros

Devoluciones

list

Parámetros

Devoluciones

list_pipelines

Parámetros

Devoluciones

list_versions

Parámetros

Devoluciones

publish

Parámetros

Devoluciones

Excepciones

reactivate

Parámetros

Devoluciones

set_default

Parámetros

Excepciones

set_default_version

Parámetros

Excepciones

set_name

Parámetros

submit

Parámetros

Devoluciones

Excepciones

Atributos

default_version

Devoluciones

description

Devoluciones

endpoint

Devoluciones

id

Devoluciones

name

Devoluciones

pipeline_version_list

Devoluciones

status

Devoluciones

swaggerurl

Devoluciones

Comentarios