Condividi tramite


PipelineEndpoint Classe

Rappresenta un Pipeline flusso di lavoro che può essere attivato da un URL univoco dell'endpoint.

È possibile usare PipelineEndpoints per creare nuove versioni di un PublishedPipeline oggetto mantenendo lo stesso endpoint. PipelineEndpoints è denominato in modo univoco all'interno di un'area di lavoro.

Usando l'attributo endpoint di un oggetto PipelineEndpoint, è possibile attivare nuove esecuzioni della pipeline da applicazioni esterne con chiamate REST. Per informazioni su come eseguire l'autenticazione quando si chiamano endpoint REST, vedere https://aka.ms/pl-restep-auth.

Per altre informazioni sulla creazione ed esecuzione di pipeline di Machine Learning, vedere https://aka.ms/pl-first-pipeline.

Inizializzare PipelineEndpoint.

Ereditarietà
builtins.object
PipelineEndpoint

Costruttore

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

Parametri

Nome Descrizione
workspace
Necessario

L'area di lavoro PipelineEndpoint è definita in.

id
Necessario
str

ID della pipelineEndpoint.

name
Necessario
str

Nome della pipelineEndpoint.

description
Necessario
str

Descrizione della pipelineEndpoint.

status
Necessario
str

Nuovo stato della pipelineEndpoint: 'Attivo' o 'Disabilitato'.

default_version
Necessario
str

La versione predefinita della pipeline in PipelineEndpoint, incrementi automatici, inizia con "0".

endpoint
Necessario
str

URL dell'endpoint REST per PipelineEndpoint, che può essere usato per inviare le esecuzioni della pipeline.

pipeline_version_list
Necessario

Elenco di oggetti PipelineIdVersion.

_pipeline_endpoint_provider
Necessario
<xref:azureml.pipeline.core._aeva_provider._AevaPublishedPipelineProvider>

Provider PipelineEndpoint.

_pipeline_endpoint_provider
Necessario

Provider PublishedPipeline.

workspace
Necessario

L'oggetto dell'area di lavoro a cui appartiene PipelineEndpoint.

id
Necessario
str

ID della pipelineEndpoint.

name
Necessario
str

Nome della pipelineEndpoint.

description
Necessario
str

Descrizione della pipelineEndpoint.

status
Necessario
str

Nuovo stato della pipelineEndpoint: 'Attivo' o 'Disabilitato'.

default_version
Necessario
str

La versione predefinita della pipeline in PipelineEndpoint, incrementi automatici, inizia con "0"

endpoint
Necessario
str

URL dell'endpoint REST per PipelineEndpoint per inviare le esecuzioni della pipeline.

pipeline_version_list
Necessario

Elenco di PipelineIdVersion

_pipeline_endpoint_provider
Necessario
<xref:azureml.pipeline.core._aeva_provider._AevaPublishedPipelineProvider>

Provider PipelineEndpoint.

_pipeline_endpoint_provider
Necessario

Provider PublishedPipeline.

swaggerendpoint
Necessario

URL dell'endpoint REST Swagger per PipelineEndpoint per inviare le esecuzioni della pipeline.

Commenti

È possibile creare un oggetto PipelineEndpoint da un Pipeline oggetto o da un PublishedPipelineoggetto .

Un esempio per la pubblicazione da una pipeline o publishPipeline è il seguente:


   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")

Inviare un oggetto PipelineEndpoint usando submit. Quando viene chiamato l'invio, viene creato un oggetto PipelineRun che a sua volta crea StepRun oggetti per ogni passaggio del flusso di lavoro.

Un esempio di come inviare un pipelineEndpoint è il seguente:


   from azureml.pipeline.core import PipelineEndpoint

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

Esistono diverse impostazioni facoltative che possono essere specificate durante l'invio di un pipelineEndpoint. Queste includono:

  • pipeline_parameters: parametri per l'esecuzione della pipeline, dizionario di {name: value}. Per informazioni dettagliate, vedere PipelineParameter.

  • parent_run_id: è possibile specificare un ID di esecuzione per impostare l'esecuzione padre di questa pipeline, che si riflette in RunHistory. L'esecuzione padre deve appartenere allo stesso esperimento di cui viene inviata la pipeline.

  • pipeline_version: versione della pipeline da eseguire.

Un esempio per inviare un pipelineEndpoint usando queste impostazioni è il seguente:


   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")

Per aggiungere una nuova versione di un uso pipelineEndpoint:


   from azureml.pipeline.core import PipelineEndpoint

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

Per altre informazioni sulla creazione e sull'uso di PipelineEndpoints, vedere il notebook seguente: https://aka.ms/pl-ver-endpoint.

Metodi

add

Aggiungere la pipeline specificata a PipelineEndpoint.

add_default

Aggiungere la pipeline specificata a PipelineEndpoint e impostare la versione predefinita per aggiungere la versione della pipeline.

archive

Archiviare pipelineEndpoint.

disable

Impostare PipelineEndpoint su "Disabilitato" e non disponibile per l'esecuzione.

enable

Impostare PipelineEndpoint su 'Active' e disponibile per l'esecuzione.

get

Ottenere pipelineEndpoint in base al nome o all'ID, genera un'eccezione se non viene specificata.

get_all

Ottenere tutti i pipelineEndpoint attivi nell'area di lavoro corrente.

Ottenere tutti i pipelineEndpoint attivi. NOTA: questo metodo è deprecato a favore di PipelineEndpoint.list().

get_all_pipelines

Ottenere l'elenco delle pipeline in PipelineEndpoint.

NOTA: questo metodo è deprecato a favore di list_pipelines()

get_all_versions

Ottenere l'elenco delle pipeline e delle versioni corrispondenti in PipelineEndpoint.

NOTA: questo metodo viene deprecato a favore di list_versions()

get_default_version

Ottenere la versione predefinita di PipelineEndpoint.

get_pipeline

Ottenere la pipeline di una versione specificata o il valore predefinito; genera un'eccezione se la versione non viene trovata.

list

Elencare pipelineEndpoint attivi nell'area di lavoro corrente.

list_pipelines

Ottenere un elenco di pipeline associate a PipelineEndpoint.

list_versions

Ottenere un elenco di pipeline e versioni corrispondenti di PipelineEndpoint.

publish

Creare un pipelineEndpoint con il nome e la pipeline e la pipeline specificata/pubblicata.

L'endpoint della pipeline è un'API REST che può essere usata dalle applicazioni esterne. Per informazioni su come eseguire l'autenticazione quando si chiamano endpoint REST, vedere https://aka.ms/pl-restep-auth.

Per altre informazioni sull'uso degli endpoint della pipeline, vedere https://aka.ms/pl-first-pipeline.

Genera eccezione se esiste già un oggetto PipelineEndpoint con il nome specificato.

reactivate

Riattivare un oggetto PipelineEndpoint archiviato.

set_default

Impostare la versione predefinita di PipelineEndpoint, genera un'eccezione se la pipeline specificata non viene trovata.

set_default_version

Impostare la versione predefinita di PipelineEndpoint, genera un'eccezione se la versione specificata non viene trovata.

set_name

Impostare il nome di PipelineEndpoint.

submit

Inviare un esperimento della pipeline della versione specificata; se la versione non è attiva la versione predefinita della pipeline.

add

Aggiungere la pipeline specificata a PipelineEndpoint.

add(pipeline)

Parametri

Nome Descrizione
pipeline
Necessario

Pipeline pubblicata da aggiungere.

add_default

Aggiungere la pipeline specificata a PipelineEndpoint e impostare la versione predefinita per aggiungere la versione della pipeline.

add_default(pipeline)

Parametri

Nome Descrizione
pipeline
Necessario

Pipeline pubblicata da aggiungere come versione predefinita.

archive

Archiviare pipelineEndpoint.

archive()

disable

Impostare PipelineEndpoint su "Disabilitato" e non disponibile per l'esecuzione.

disable()

enable

Impostare PipelineEndpoint su 'Active' e disponibile per l'esecuzione.

enable()

get

Ottenere pipelineEndpoint in base al nome o all'ID, genera un'eccezione se non viene specificata.

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

Parametri

Nome Descrizione
workspace
Necessario

L'area di lavoro PipelineEndpoint è stata creata.

id
str

ID della pipelineEndpoint.

Valore predefinito: None
name
str

Nome della pipelineEndpoint.

Valore predefinito: None
_workflow_provider
<xref:azureml.pipeline.core._aeva_provider._AevaWorkflowProvider>

Provider del flusso di lavoro.

Valore predefinito: None
_service_endpoint
str

Endpoint del servizio.

Valore predefinito: None

Restituisce

Tipo Descrizione

Oggetto PipelineEndpoint.

get_all

Ottenere tutti i pipelineEndpoint attivi nell'area di lavoro corrente.

Ottenere tutti i pipelineEndpoint attivi. NOTA: questo metodo è deprecato a favore di PipelineEndpoint.list().

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

Parametri

Nome Descrizione
workspace
Necessario

Area di lavoro.

active_only

Se true, restituisce solo pipelineEndpoint attualmente attivi.

Valore predefinito: True
_workflow_provider
<xref:azureml.pipeline.core._aeva_provider._AevaWorkflowProvider>

Provider del flusso di lavoro.

Valore predefinito: None
_service_endpoint
str

Endpoint del servizio.

Valore predefinito: None

Restituisce

Tipo Descrizione

Elenco di oggetti PipelineEndpoint.

get_all_pipelines

Ottenere l'elenco delle pipeline in PipelineEndpoint.

NOTA: questo metodo è deprecato a favore di list_pipelines()

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

Parametri

Nome Descrizione
active_only

Contrassegno per restituire solo pipeline attive.

Valore predefinito: True
_workflow_provider
<xref:azureml.pipeline.core._aeva_provider._AevaWorkflowProvider>

Provider del flusso di lavoro.

Valore predefinito: None
_service_endpoint
str

Endpoint del servizio.

Valore predefinito: None

Restituisce

Tipo Descrizione

Elenco di oggetti PublishedPipeline.

get_all_versions

Ottenere l'elenco delle pipeline e delle versioni corrispondenti in PipelineEndpoint.

NOTA: questo metodo viene deprecato a favore di list_versions()

get_all_versions(_workflow_provider=None, _service_endpoint=None)

Parametri

Nome Descrizione
_workflow_provider
<xref:azureml.pipeline.core._aeva_provider._AevaWorkflowProvider>

Provider del flusso di lavoro.

Valore predefinito: None
_service_endpoint
str

Endpoint del servizio.

Valore predefinito: None

Restituisce

Tipo Descrizione

Elenco di oggetti PipelineVersion.

get_default_version

Ottenere la versione predefinita di PipelineEndpoint.

get_default_version()

Restituisce

Tipo Descrizione
str

Versione predefinita dell'endpoint della pipeline.

get_pipeline

Ottenere la pipeline di una versione specificata o il valore predefinito; genera un'eccezione se la versione non viene trovata.

get_pipeline(version=None)

Parametri

Nome Descrizione
version
str

Versione della pipeline da restituire.

Valore predefinito: None

Restituisce

Tipo Descrizione

Pipeline pubblicata.

list

Elencare pipelineEndpoint attivi nell'area di lavoro corrente.

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

Parametri

Nome Descrizione
workspace
Necessario

Area di lavoro.

active_only

Se true, restituisce solo pipelineEndpoint attualmente attivi.

Valore predefinito: True
max_results
int

max line of returned PipelineEndpoints

Valore predefinito: 100
_workflow_provider
<xref:azureml.pipeline.core._aeva_provider._AevaWorkflowProvider>

Provider del flusso di lavoro.

Valore predefinito: None
_service_endpoint
str

Endpoint del servizio.

Valore predefinito: None

Restituisce

Tipo Descrizione

Elenco di oggetti PipelineEndpoint.

list_pipelines

Ottenere un elenco di pipeline associate a PipelineEndpoint.

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

Parametri

Nome Descrizione
active_only

Indica se restituire solo pipeline attive.

Valore predefinito: True
_workflow_provider
<xref:azureml.pipeline.core._aeva_provider._AevaWorkflowProvider>

Provider del flusso di lavoro.

Valore predefinito: None
_service_endpoint
str

Endpoint del servizio.

Valore predefinito: None

Restituisce

Tipo Descrizione

Elenco di oggetti PublishedPipeline.

list_versions

Ottenere un elenco di pipeline e versioni corrispondenti di PipelineEndpoint.

list_versions(_workflow_provider=None, _service_endpoint=None)

Parametri

Nome Descrizione
_workflow_provider
<xref:azureml.pipeline.core._aeva_provider._AevaWorkflowProvider>

Provider del flusso di lavoro.

Valore predefinito: None
_service_endpoint
str

Endpoint del servizio.

Valore predefinito: None

Restituisce

Tipo Descrizione

Elenco di oggetti PipelineVersion.

publish

Creare un pipelineEndpoint con il nome e la pipeline e la pipeline specificata/pubblicata.

L'endpoint della pipeline è un'API REST che può essere usata dalle applicazioni esterne. Per informazioni su come eseguire l'autenticazione quando si chiamano endpoint REST, vedere https://aka.ms/pl-restep-auth.

Per altre informazioni sull'uso degli endpoint della pipeline, vedere https://aka.ms/pl-first-pipeline.

Genera eccezione se esiste già un oggetto PipelineEndpoint con il nome specificato.

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

Parametri

Nome Descrizione
workspace
Necessario

Area di lavoro in cui creare PipelineEndpoint.

name
Necessario
str

Nome della pipelineEndpoint.

description
Necessario
str

Descrizione della pipelineEndpoint.

pipeline
Necessario

Pipeline o pipeline pubblicate.

_service_endpoint
str

Endpoint del servizio.

Valore predefinito: None
_workflow_provider
<xref:azureml.pipeline.core._aeva_provider._AevaWorkflowProvider>

Provider del flusso di lavoro.

Valore predefinito: None

Restituisce

Tipo Descrizione

Nuovo PipelineEndpoint.

Eccezioni

Tipo Descrizione

reactivate

Riattivare un oggetto PipelineEndpoint archiviato.

reactivate(name)

Parametri

Nome Descrizione
name
Necessario
str

Nome da impostare.

Restituisce

Tipo Descrizione

Oggetto PipelineEndpoint.

set_default

Impostare la versione predefinita di PipelineEndpoint, genera un'eccezione se la pipeline specificata non viene trovata.

set_default(pipeline)

Parametri

Nome Descrizione
pipeline
Necessario

Pipeline pubblicata da impostare come impostazione predefinita.

Eccezioni

Tipo Descrizione

set_default_version

Impostare la versione predefinita di PipelineEndpoint, genera un'eccezione se la versione specificata non viene trovata.

set_default_version(version)

Parametri

Nome Descrizione
version
Necessario
str

Versione da impostare come versione predefinita in PipelineEndpoint.

Eccezioni

Tipo Descrizione

set_name

Impostare il nome di PipelineEndpoint.

set_name(name)

Parametri

Nome Descrizione
name
Necessario
str

Nome da impostare.

submit

Inviare un esperimento della pipeline della versione specificata; se la versione non è attiva la versione predefinita della pipeline.

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

Parametri

Nome Descrizione
experiment_name
Necessario
str

Nome dell'esperimento in cui inviare la pipeline.

pipeline_parameters

Parametri da usare nell'esecuzione della pipeline, passati come dizionario di {name: value}. Per informazioni dettagliate, vedere PipelineParameter.

Valore predefinito: None
parent_run_id
str

È possibile specificare un ID di esecuzione per impostare l'esecuzione padre di questa pipeline, che viene riflessa in RunHistory. L'esecuzione padre deve appartenere allo stesso esperimento a cui viene inviata la pipeline.

Valore predefinito: None
pipeline_version
str

Versione della pipeline da eseguire.

Valore predefinito: None

Restituisce

Tipo Descrizione

Esecuzione della pipeline inviata.

Eccezioni

Tipo Descrizione

Attributi

default_version

Ottenere la versione predefinita di PipelineEndpoint.

Restituisce

Tipo Descrizione
str

Versione predefinita.

description

Ottenere la descrizione di PipelineEndpoint.

Restituisce

Tipo Descrizione
str

Descrizione.

endpoint

Ottenere l'URL dell'endpoint REST della pipelineEndpoint.

L'endpoint può essere usato per attivare le esecuzioni della pipeline.

Restituisce

Tipo Descrizione
str

Endpoint REST per PipelineEndpoint per l'esecuzione della pipeline.

id

Ottenere l'ID della pipelineEndpoint.

Restituisce

Tipo Descrizione
str

ID della pipelineEndpoint.

name

Ottenere il nome della pipelineEndpoint.

Restituisce

Tipo Descrizione
str

Nome.

pipeline_version_list

Ottenere l'elenco delle versioni della pipeline.

Restituisce

Tipo Descrizione

Elenco di oggetti PipelineIdVersion.

status

Ottenere lo stato di PipelineEndpoint.

Restituisce

Tipo Descrizione
str

Stato.

swaggerurl

Ottenere l'URL Swagger REST della pipelineEndpoint.

L'URL Swagger può essere visualizzato lo schema dell'endpoint della pipeline.

Restituisce

Tipo Descrizione
str

REST Swagger per PipelineEndpoint per eseguire la pipeline.