PublishedPipeline Classe
Rappresenta una pipeline da inviare senza il codice Python che l'ha costruito.
Inoltre, è possibile usare un oggetto PublishedPipeline per inviare nuovamente un oggetto Pipeline con valori e input diversi PipelineParameter .
Inizializzare PublishedPipeline.
:p aram endpoint REST URL 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 area di lavoro: area di lavoro dell'area di lavoro 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.HasPipelinePortalPublishedPipeline
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
- continue_on_step_failure
- bool
Indica se continuare l'esecuzione di altri passaggi in PipelineRun se un passaggio ha esito negativo. Il valore predefinito è false.
- _pipeline_provider
- <xref:azureml.pipeline.core._workflow_provider._PublishedPipelineProvider>
Provider di pipeline pubblicato.
- _pipeline_provider
- <xref:azureml.pipeline.core._workflow_provider._PublishedPipelineProvider>
Provider di pipeline pubblicato.
Commenti
È possibile creare un oggetto PublishedPipeline da un Pipeline oggetto o da un PipelineRunoggetto .
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 pubblicare 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 di 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 si interrompe, annullando eventuali passaggi in esecuzione.
Inviare un oggetto PublishedPipeline 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 per inviare un file PublishedPipeline è il seguente:
from azureml.pipeline.core import PublishedPipeline
published_pipeline = PublishedPipeline.get(workspace=ws, id="published_pipeline_id")
pipeline_run = experiment.submit(published_pipeline)
Esistono diverse impostazioni facoltative che possono essere specificate durante l'invio di un oggetto PublishedPipeline. 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 l'esecuzione. 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 di 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 file 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 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 di ripetizione del training, ad esempio. Per altre informazioni, vedere https://aka.ms/pl-first-pipeline.
Metodi
| disable |
Impostare la pipeline pubblicata su "Disabled" 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 è 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 il file YAML della pipeline in un file. Attualmente, per l'esportazione YAML sono supportate solo le pipeline costituite da ModuleSteps. |
| submit |
Inviare la pipeline pubblicata. Equivale all'uso di submit. Restituisce l'oggetto inviato PipelineRun. Usare questo oggetto per monitorare e visualizzare i dettagli dell'esecuzione. |
disable
Impostare la pipeline pubblicata su "Disabled" 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
- _workflow_provider
- <xref:azureml.pipeline.core._aeva_provider._AevaWorkflowProvider>
Provider del flusso di lavoro.
Restituisce
Oggetto PublishedPipeline.
Tipo restituito
get_all
Ottenere tutte le pipeline pubblicate nell'area di lavoro corrente.
DEPRECATO: questo metodo è deprecato a favore del metodo PublishedPipeline list .
static get_all(workspace, active_only=True, _service_endpoint=None)Parametri
- active_only
- bool
Indica se restituire solo le pipeline pubblicate attualmente attive.
Restituisce
Elenco di oggetti PublishedPipeline.
Tipo restituito
get_graph
Ottenere il grafico di PublishedPipeline.
get_graph(_workflow_provider=None)Parametri
- _workflow_provider
- <xref:azureml.pipeline.core._aeva_provider._AevaWorkflowProvider>
Provider del flusso di lavoro.
Restituisce
Grafico.
Tipo restituito
get_step_names
Ottenere l'elenco dei nomi dei passaggi in PublishedPipeline.
get_step_names(_workflow_provider=None)Parametri
- _workflow_provider
- <xref:azureml.pipeline.core._aeva_provider._AevaWorkflowProvider>
Provider del flusso di lavoro.
Restituisce
Elenco dei nomi dei passaggi in PublishedPipeline.
Tipo restituito
list
Ottenere tutte le pipeline pubblicate nell'area di lavoro corrente.
static list(workspace, active_only=True, _service_endpoint=None)Parametri
- active_only
- bool
Indica se restituire solo le pipeline pubblicate attualmente attive.
Restituisce
Elenco di oggetti PublishedPipeline.
Tipo restituito
save
Salvare il file YAML della pipeline in un file.
Attualmente, per l'esportazione YAML sono supportate solo le pipeline costituite da ModuleSteps.
save(path=None, _workflow_provider=None)Parametri
- path
- str
Percorso in cui salvare il file YAML. Se il percorso è una directory, il file YAML della pipeline viene salvato nel percorso/pipeline_name.yml. Se path è None, viene utilizzata la directory corrente.
- _workflow_provider
- <xref:azureml.pipeline.core._aeva_provider._AevaWorkflowProvider>
Provider del flusso di lavoro.
Tipo restituito
submit
Inviare la pipeline pubblicata. Equivale all'uso di submit.
Restituisce l'oggetto inviato PipelineRun. Usare 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
- pipeline_parameters
- dict
Dizionario di parametri per assegnare nuovi valori {nome param, valore param}. Per informazioni dettagliate, vedere PipelineParameter.
- _workflow_provider
- <xref:azureml.pipeline.core._aeva_provider._AevaWorkflowProvider>
Provider del flusso di lavoro.
- parent_run_id
- str
ID esecuzione facoltativo da impostare per l'esecuzione padre di questa esecuzione della pipeline, che si riflette in RunHistory. L'esecuzione padre deve appartenere allo stesso esperimento a cui viene inviata la pipeline.
- 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.
Restituisce
Esecuzione della pipeline inviata.
Tipo restituito
Attributi
continue_on_step_failure
Ottiene il valore dell'impostazione continue_on_step_failure .
Restituisce
Valore dell'impostazione continue_on_step_failure .
Tipo restituito
description
Ottenere la descrizione della pipeline pubblicata.
Restituisce
Descrizione della pipeline pubblicata.
Tipo restituito
endpoint
Ottenere l'URL dell'endpoint REST per l'esecuzione di una pipeline pubblicata.
Restituisce
URL dell'endpoint REST per l'esecuzione della pipeline pubblicata.
Tipo restituito
graph_id
Ottenere l'ID del grafico per questa pipeline pubblicata.
Restituisce
ID del grafico.
Tipo restituito
id
Ottenere l'ID della pipeline pubblicata.
Restituisce
ID della pipeline pubblicata.
Tipo restituito
name
Ottenere il nome della pipeline pubblicata.
Restituisce
Nome della pipeline pubblicata.
Tipo restituito
status
Ottenere lo stato della pipeline pubblicata.
Restituisce
Stato della pipeline pubblicata.
Tipo restituito
total_run_steps
Ottenere il numero di passaggi nella pipeline.
Restituisce
Numero di passaggi nella pipeline.
Tipo restituito
version
Ottenere la versione della pipeline pubblicata.
Restituisce
Versione della pipeline pubblicata.
Tipo restituito
Commenti e suggerimenti
Presto disponibile: Nel corso del 2024 verranno gradualmente disattivati i problemi di GitHub come meccanismo di feedback per il contenuto e ciò verrà sostituito con un nuovo sistema di feedback. Per altre informazioni, vedere https://aka.ms/ContentUserFeedback.
Invia e visualizza il feedback per