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.objectPipelineEndpoint
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
|
ID della pipelineEndpoint. |
name
Necessario
|
Nome della pipelineEndpoint. |
description
Necessario
|
Descrizione della pipelineEndpoint. |
status
Necessario
|
Nuovo stato della pipelineEndpoint: 'Attivo' o 'Disabilitato'. |
default_version
Necessario
|
La versione predefinita della pipeline in PipelineEndpoint, incrementi automatici, inizia con "0". |
endpoint
Necessario
|
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
|
ID della pipelineEndpoint. |
name
Necessario
|
Nome della pipelineEndpoint. |
description
Necessario
|
Descrizione della pipelineEndpoint. |
status
Necessario
|
Nuovo stato della pipelineEndpoint: 'Attivo' o 'Disabilitato'. |
default_version
Necessario
|
La versione predefinita della pipeline in PipelineEndpoint, incrementi automatici, inizia con "0" |
endpoint
Necessario
|
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
|
ID della pipelineEndpoint. Valore predefinito: None
|
name
|
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
|
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
|
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
|
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
|
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 |
---|---|
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
|
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
|
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
|
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
|
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
|
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
|
Nome della pipelineEndpoint. |
description
Necessario
|
Descrizione della pipelineEndpoint. |
pipeline
Necessario
|
PublishedPipeline oppure
Pipeline
Pipeline o pipeline pubblicate. |
_service_endpoint
|
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
|
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
|
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
|
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
|
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
|
È 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
|
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 |
---|---|
Versione predefinita. |
description
endpoint
Ottenere l'URL dell'endpoint REST della pipelineEndpoint.
L'endpoint può essere usato per attivare le esecuzioni della pipeline.
Restituisce
Tipo | Descrizione |
---|---|
Endpoint REST per PipelineEndpoint per l'esecuzione della pipeline. |
id
name
pipeline_version_list
Ottenere l'elenco delle versioni della pipeline.
Restituisce
Tipo | Descrizione |
---|---|
Elenco di oggetti PipelineIdVersion. |
status
swaggerurl
Ottenere l'URL Swagger REST della pipelineEndpoint.
L'URL Swagger può essere visualizzato lo schema dell'endpoint della pipeline.
Restituisce
Tipo | Descrizione |
---|---|
REST Swagger per PipelineEndpoint per eseguire la pipeline. |