PublishedPipeline Classe

Riferimento

Rappresenta una pipeline da inviare senza il codice Python che lo ha costruito.

Inoltre, è possibile usare una proprietà PublishedPipeline per inviare di nuovo un oggetto Pipeline con valori e input diversi PipelineParameter .

Inizializzare PublishedPipeline.

:p aram endpoint L'URL dell'endpoint REST per inviare le esecuzioni della pipeline per questa pipeline. :type endpoint: str :p aram total_run_steps: numero di passaggi in questa pipeline :type total_run_steps: int :p aram workspace: l'area di lavoro della pipeline pubblicata. :type workspace: azureml.core.Workspace :p aram continue_on_step_failure: Indica se continuare l'esecuzione di altri passaggi in PipelineRun

se un passaggio ha esito negativo, il valore predefinito è false.

Ereditarietà: azureml.core._portal.HasPipelinePortal

PublishedPipeline

Costruttore

PublishedPipeline(name, graph_id, description, version, published_pipeline_id, status, endpoint, total_run_steps, workspace, continue_on_step_failure=None, _pipeline_provider=None, **kwargs)

Parametri

Nome	Descrizione
name Necessario	str Nome della pipeline pubblicata.
graph_id Necessario	str ID del grafico per questa pipeline pubblicata.
description Necessario	str Descrizione della pipeline pubblicata.
version Necessario	str Versione della pipeline pubblicata.
published_pipeline_id Necessario	str ID della pipeline pubblicata.
status Necessario	str Stato della pipeline pubblicata ('Active' o 'Disabilitato').
endpoint Necessario	str URL dell'endpoint REST da inviare per questa pipeline.
total_run_steps Necessario	int Numero di passaggi in questa pipeline.
workspace Necessario	Workspace Area di lavoro della pipeline pubblicata.
continue_on_step_failure Necessario	bool Se continuare l'esecuzione di altri passaggi in PipelineRun se un passaggio ha esito negativo. Il valore predefinito è false.
_pipeline_provider Necessario	<xref:azureml.pipeline.core._workflow_provider._PublishedPipelineProvider> Provider di pipeline pubblicato.
kwargs Necessario	dict Argomenti parole chiave personalizzati, riservati per lo sviluppo futuro
name Necessario	str Nome della pipeline pubblicata.
graph_id Necessario	str ID del grafico per questa pipeline pubblicata.
description Necessario	str Descrizione della pipeline pubblicata.
version Necessario	str Versione della pipeline pubblicata.
published_pipeline_id Necessario	str ID della pipeline pubblicata.
status Necessario	str Stato della pipeline pubblicata ('Attivo' o 'Disabilitato').
_pipeline_provider Necessario	<xref:azureml.pipeline.core._workflow_provider._PublishedPipelineProvider> Provider di pipeline pubblicato.
kwargs Necessario	dict Argomenti parole chiave personalizzati, riservati per lo sviluppo futuro

Commenti

È possibile creare una proprietà PublishedPipeline da o Pipeline .PipelineRun

Un esempio di pubblicazione da una pipeline è il seguente:


   from azureml.pipeline.core import Pipeline

   pipeline = Pipeline(workspace=ws, steps=steps)
   published_pipeline = pipeline.publish(name="My_New_Pipeline",
                                         description="My New Pipeline Description",
                                         version="1.0",
                                         continue_on_step_failure=True)

Per eseguire la pubblicazione da un oggetto PipelineRun, usare:


   from azureml.pipeline.core import PipelineRun

   pipeline_run = PipelineRun(experiment=Experiment(ws, "Pipeline_experiment"), run_id="run_id")
   published_pipeline = pipeline_run.publish_pipeline(name="My_New_Pipeline",
                                                      description="My New Pipeline Description",
                                                      version="1.0",
                                                      continue_on_step_failure=True)

Nota: il parametro continue_on_step_failure specifica se l'esecuzione dei passaggi nella pipeline continuerà se un passaggio ha esito negativo. Il valore predefinito è False, ovvero quando un passaggio ha esito negativo, l'esecuzione della pipeline verrà arrestata, annullando tutti i passaggi in esecuzione.

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

Di seguito è riportato un esempio di invio di publishedPipeline:


   from azureml.pipeline.core import PublishedPipeline

   published_pipeline = PublishedPipeline.get(workspace=ws, id="published_pipeline_id")
   pipeline_run = experiment.submit(published_pipeline)

Durante l'invio di un elemento PublishedPipeline è possibile specificare diverse impostazioni facoltative. Queste includono:

continue_on_step_failure: indica se continuare l'esecuzione di altri passaggi in PipelineRun se un passaggio ha esito negativo, facoltativo. Solo i passaggi che non hanno alcuna dipendenza dall'output del passaggio non riuscito continueranno a essere eseguiti. Se specificato, questa impostazione di parametro esegue l'override dell'impostazione nella pipeline.
pipeline_parameters: parametri per l'esecuzione della pipeline, dizionario di {name: value}. Per informazioni dettagliate, vedere PipelineParameter.
parent_run_id: è possibile specificare un ID esecuzione per impostare l'esecuzione padre di questa pipeline, che si riflette in RunHistory. L'esecuzione padre deve appartenere allo stesso esperimento della pipeline inviata.

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


   from azureml.pipeline.core import PublishedPipeline

   published_pipeline = PublishedPipeline.get(workspace=ws, id="published_pipeline_id")
   pipeline_run = experiment.submit(published_pipeline,
                                    continue_on_step_failure=True,
                                    pipeline_parameters={"param1": "value1"},
                                    parent_run_id="<run_id>")

Tutte le pipeline pubblicate hanno un endpoint REST Con l'endpoint della pipeline è possibile attivare un'esecuzione della pipeline da sistemi esterni, ad esempio client non Python. Per informazioni su come eseguire l'autenticazione quando si chiamano gli endpoint REST, vedere https://aka.ms/pl-restep-auth.

L'uso dell'endpoint consente la "ripetibilità gestita" negli scenari di assegnazione dei punteggi batch e ripetizione del training, ad esempio. Per altre informazioni, vedere https://aka.ms/pl-first-pipeline.

Metodi

disable	Impostare la pipeline pubblicata su "Disabilitata" e non disponibile per l'esecuzione.
enable	Impostare la pipeline pubblicata su 'Active' e disponibile per l'esecuzione.
get	Ottenere la pipeline pubblicata.
get_all	Ottenere tutte le pipeline pubblicate nell'area di lavoro corrente. DEPRECATO: questo metodo viene deprecato a favore del metodo PublishedPipeline list .
get_graph	Ottenere il grafico di PublishedPipeline.
get_step_names	Ottenere l'elenco dei nomi dei passaggi in PublishedPipeline.
list	Ottenere tutte le pipeline pubblicate nell'area di lavoro corrente.
save	Salvare la pipeline YAML in un file. Attualmente, solo le pipeline costituite da ModuleSteps sono supportate per l'esportazione di YAML.
submit	Inviare la pipeline pubblicata. Equivale all'uso submitdi . Restituisce l'oggetto inviato PipelineRun. Utilizzare questo oggetto per monitorare e visualizzare i dettagli dell'esecuzione.

disable

Impostare la pipeline pubblicata su "Disabilitata" e non disponibile per l'esecuzione.

disable()

enable

Impostare la pipeline pubblicata su 'Active' e disponibile per l'esecuzione.

enable()

get

Ottenere la pipeline pubblicata.

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

Parametri

Nome	Descrizione
workspace Necessario	Workspace L'area di lavoro in cui è stata creata la pipeline pubblicata.
id Necessario	str ID della pipeline pubblicata.
_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
PublishedPipeline	Oggetto PublishedPipeline.

get_all

Ottenere tutte le pipeline pubblicate nell'area di lavoro corrente.

DEPRECATO: questo metodo viene deprecato a favore del metodo PublishedPipeline list .

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

Parametri

Nome	Descrizione
workspace Necessario	Workspace L'area di lavoro in cui è stata creata la pipeline pubblicata.
active_only	bool Se restituire solo pipeline pubblicate attualmente attive. Valore predefinito: True
_service_endpoint	str Endpoint del servizio. Valore predefinito: None

Restituisce

Tipo	Descrizione
list[PublishedPipeline]	Elenco di oggetti PublishedPipeline.

get_graph

Ottenere il grafico di PublishedPipeline.

get_graph(_workflow_provider=None)

Parametri

Nome	Descrizione
_workflow_provider	<xref:azureml.pipeline.core._aeva_provider._AevaWorkflowProvider> Provider del flusso di lavoro. Valore predefinito: None

Restituisce

Tipo	Descrizione
Graph	Grafico.

get_step_names

Ottenere l'elenco dei nomi dei passaggi in PublishedPipeline.

get_step_names(_workflow_provider=None)

Parametri

Nome	Descrizione
_workflow_provider	<xref:azureml.pipeline.core._aeva_provider._AevaWorkflowProvider> Provider del flusso di lavoro. Valore predefinito: None

Restituisce

Tipo	Descrizione
List[str]	Elenco dei nomi dei passaggi in PublishedPipeline.

list

Ottenere tutte le pipeline pubblicate nell'area di lavoro corrente.

static list(workspace, active_only=True, _service_endpoint=None)

Parametri

Nome	Descrizione
workspace Necessario	Workspace L'area di lavoro in cui è stata creata la pipeline pubblicata.
active_only	bool Se restituire solo pipeline pubblicate attualmente attive. Valore predefinito: True
_service_endpoint	str Endpoint del servizio. Valore predefinito: None

Restituisce

Tipo	Descrizione
list[PublishedPipeline]	Elenco di oggetti PublishedPipeline.

save

Salvare la pipeline YAML in un file.

Attualmente, solo le pipeline costituite da ModuleSteps sono supportate per l'esportazione di YAML.

save(path=None, _workflow_provider=None)

Parametri

Nome	Descrizione
path	str Percorso in cui salvare YAML. Se il percorso è una directory, il file YAML della pipeline viene salvato nel percorso/pipeline_name.yml. Se il percorso è Nessuno, viene usata la directory corrente. Valore predefinito: None
_workflow_provider	<xref:azureml.pipeline.core._aeva_provider._AevaWorkflowProvider> Provider del flusso di lavoro. Valore predefinito: None

Restituisce

Tipo	Descrizione
None

submit

Inviare la pipeline pubblicata. Equivale all'uso submitdi .

Restituisce l'oggetto inviato PipelineRun. Utilizzare questo oggetto per monitorare e visualizzare i dettagli dell'esecuzione.

submit(workspace, experiment_name, pipeline_parameters=None, _workflow_provider=None, _service_endpoint=None, parent_run_id=None, continue_on_step_failure=None)

Parametri

Nome	Descrizione
workspace Necessario	Workspace Area di lavoro in cui inviare la pipeline pubblicata.
experiment_name Necessario	str Nome dell'esperimento da inviare.
pipeline_parameters	dict Dizionario dei parametri per assegnare nuovi valori {param name, param value}. Per informazioni dettagliate, vedere PipelineParameter. 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
parent_run_id	str ID esecuzione facoltativo da impostare per 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
continue_on_step_failure	bool Indica se continuare l'esecuzione di altri passaggi in PipelineRun se un passaggio ha esito negativo, facoltativo. Se specificato, eseguirà l'override dell'impostazione nella pipeline. Valore predefinito: None

Restituisce

Tipo	Descrizione
PipelineRun	Esecuzione della pipeline inviata.

Attributi

continue_on_step_failure

Ottenere il valore dell'impostazione continue_on_step_failure .

Restituisce

Tipo	Descrizione
bool	Valore dell'impostazione `continue_on_step_failure` .

description

Ottenere la descrizione della pipeline pubblicata.

Restituisce

Tipo	Descrizione
str	Descrizione della pipeline pubblicata.

endpoint

Ottenere l'URL dell'endpoint REST per l'esecuzione di una pipeline pubblicata.

Restituisce

Tipo	Descrizione
str	URL dell'endpoint REST per l'esecuzione della pipeline pubblicata.

graph_id

Ottenere l'ID del grafico per questa pipeline pubblicata.

Restituisce

Tipo	Descrizione
str	ID del grafico.

id

Ottenere l'ID della pipeline pubblicata.

Restituisce

Tipo	Descrizione
str	ID della pipeline pubblicata.

name

Ottenere il nome della pipeline pubblicata.

Restituisce

Tipo	Descrizione
str	Nome della pipeline pubblicato.

status

Ottenere lo stato della pipeline pubblicata.

Restituisce

Tipo	Descrizione
str	Stato della pipeline pubblicata.

total_run_steps

Ottenere il numero di passaggi nella pipeline.

Restituisce

Tipo	Descrizione
int	Numero di passaggi nella pipeline.

version

Ottenere la versione della pipeline pubblicata.

Restituisce

Tipo	Descrizione
str	Versione della pipeline pubblicata.

Condividi tramite

PublishedPipeline Classe

Costruttore

Parametri

Commenti

Metodi

disable

enable

get

Parametri

Restituisce

get_all

Parametri

Restituisce

get_graph

Parametri

Restituisce

get_step_names

Parametri

Restituisce

list

Parametri

Restituisce

save

Parametri

Restituisce

submit

Parametri

Restituisce

Attributi

continue_on_step_failure

Restituisce

description

Restituisce

endpoint

Restituisce

graph_id

Restituisce

id

Restituisce

name

Restituisce

status

Restituisce

total_run_steps

Restituisce

version

Restituisce

Commenti e suggerimenti

Risorse aggiuntive