PublishedPipeline Třída

Představuje kanál, který se má odeslat bez kódu Pythonu, který ho vytvořil.

Kromě toho je možné k opětovnému odeslání Pipeline s různými PipelineParameter hodnotami a vstupy použít Publikovanýpipeline.

Inicializujte publishedPipeline.

koncový bod :p aram Adresa URL koncového bodu REST pro odeslání spuštění kanálu pro tento kanál. :type endpoint: str :p aram total_run_steps: Počet kroků v tomto kanálu :type total_run_steps: int :p aram workspace: Pracovní prostor publikovaného kanálu. :type workspace: azureml.core.Workspace :p aram continue_on_step_failure: Jestli chcete pokračovat v provádění dalších kroků ve spuštění kanálu

Pokud se krok nezdaří, výchozí hodnota je false.

Dědičnost
azureml.core._portal.HasPipelinePortal
PublishedPipeline

Konstruktor

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

Parametry

Name Description
name
Vyžadováno
str

Název publikovaného kanálu.

graph_id
Vyžadováno
str

ID grafu pro tento publikovaný kanál.

description
Vyžadováno
str

Popis publikovaného kanálu.

version
Vyžadováno
str

Publikovaná verze kanálu.

published_pipeline_id
Vyžadováno
str

ID publikovaného kanálu.

status
Vyžadováno
str

Stav publikovaného kanálu (Aktivní nebo Zakázáno).

endpoint
Vyžadováno
str

Adresa URL koncového bodu REST pro odeslání se spustí pro tento kanál.

total_run_steps
Vyžadováno
int

Počet kroků v tomto kanálu

workspace
Vyžadováno

Pracovní prostor publikovaného kanálu.

continue_on_step_failure
Vyžadováno

Jestli chcete pokračovat v provádění dalších kroků v části PipelineRun v případě selhání kroku. Výchozí hodnotou je hodnota false.

_pipeline_provider
Vyžadováno
<xref:azureml.pipeline.core._workflow_provider._PublishedPipelineProvider>

Publikovaný poskytovatel kanálu.

kwargs
Vyžadováno

Argumenty vlastních klíčových slov vyhrazené pro budoucí vývoj

name
Vyžadováno
str

Název publikovaného kanálu.

graph_id
Vyžadováno
str

ID grafu pro tento publikovaný kanál.

description
Vyžadováno
str

Popis publikovaného kanálu.

version
Vyžadováno
str

Publikovaná verze kanálu.

published_pipeline_id
Vyžadováno
str

ID publikovaného kanálu.

status
Vyžadováno
str

Stav publikovaného kanálu (Aktivní nebo Zakázáno).

_pipeline_provider
Vyžadováno
<xref:azureml.pipeline.core._workflow_provider._PublishedPipelineProvider>

Publikovaný poskytovatel kanálu.

kwargs
Vyžadováno

Argumenty vlastních klíčových slov vyhrazené pro budoucí vývoj

Poznámky

Publikovanýpipeline lze vytvořit buď z objektu PipelineRun, Pipeline nebo .

Příklad publikování z kanálu je následující:


   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)

K publikování ze spuštění kanálu použijte:


   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)

Poznámka: Parametr continue_on_step_failure určuje, jestli bude provádění kroků v kanálu pokračovat, pokud jeden krok selže. Výchozí hodnota je False, což znamená, že když jeden krok selže, provádění kanálu se zastaví a zruší se všechny spuštěné kroky.

Odešlete publikovanýpipeline pomocí submit. Při volání příkazu submit se vytvoří objekt , PipelineRun který následně vytvoří StepRun objekty pro každý krok v pracovním postupu.

Příklad odeslání PublishedPipeline je následující:


   from azureml.pipeline.core import PublishedPipeline

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

Při odesílání publikovanéhopipeline je možné zadat řadu volitelných nastavení. Tady jsou některé z nich:

  • continue_on_step_failure: Volitelné, jestli chcete pokračovat ve provádění dalších kroků v kanáluSpustit v případě selhání kroku. Pouze kroky, které nejsou závislé na výstupu neúspěšného kroku, budou pokračovat v provádění. Pokud je toto nastavení parametru zadané, přepíše nastavení v kanálu.

  • pipeline_parameters: Parametry spuštění kanálu, slovník {name: value}. Další podrobnosti najdete PipelineParameter v tématu .

  • parent_run_id: Můžete zadat ID spuštění, které nastaví nadřazené spuštění tohoto spuštění kanálu, což se projeví ve funkci RunHistory. Nadřazené spuštění musí patřit do stejného experimentu jako odesílaný kanál.

Příklad odeslání PublishedPipeline pomocí těchto nastavení:


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

Všechny publikované kanály mají koncový bod REST. Pomocí koncového bodu kanálu můžete aktivovat spuštění kanálu z externích systémů, jako jsou klienti bez Pythonu. Informace o ověřování při volání koncových bodů REST najdete v tématu https://aka.ms/pl-restep-auth.

Použití koncového bodu umožňuje "spravovanou opakovatelnost" například ve scénářích dávkového vyhodnocování a přetrénování. Další informace naleznete v tématu https://aka.ms/pl-first-pipeline.

Metody

disable

Nastavte publikovaný kanál na Zakázáno a není k dispozici ke spuštění.

enable

Nastavte publikovaný kanál na Aktivní a můžete ho spustit.

get

Získejte publikovaný kanál.

get_all

Získejte všechny publikované kanály v aktuálním pracovním prostoru.

ZASTARALÉ: Tato metoda je zastaralá ve prospěch metody PublishedPipeline list .

get_graph

Získejte graf publikovanéhopipeline.

get_step_names

Seznam názvů kroků získáte v části PublishedPipeline.

list

Získejte všechny publikované kanály v aktuálním pracovním prostoru.

save

Uložte YAML kanálu do souboru.

V současné době se pro export YAML podporují pouze kanály, které se skládají z moduleSteps.

submit

Odešlete publikovaný kanál. Jedná se o ekvivalent použití submit.

Vrátí odeslanou PipelineRunhodnotu . Tento objekt slouží k monitorování a zobrazení podrobností spuštění.

disable

Nastavte publikovaný kanál na Zakázáno a není k dispozici ke spuštění.

disable()

enable

Nastavte publikovaný kanál na Aktivní a můžete ho spustit.

enable()

get

Získejte publikovaný kanál.

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

Parametry

Name Description
workspace
Vyžadováno

Pracovní prostor, ve které byl publikovaný kanál vytvořen.

id
Vyžadováno
str

ID publikovaného kanálu.

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

Poskytovatel pracovního postupu.

výchozí hodnota: None
_service_endpoint
str

Koncový bod služby.

výchozí hodnota: None

Návraty

Typ Description

Objekt PublishedPipeline.

get_all

Získejte všechny publikované kanály v aktuálním pracovním prostoru.

ZASTARALÉ: Tato metoda je zastaralá ve prospěch metody PublishedPipeline list .

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

Parametry

Name Description
workspace
Vyžadováno

Pracovní prostor, ve které byl publikovaný kanál vytvořen.

active_only

Jestli se mají vracet jenom publikované kanály, které jsou aktuálně aktivní.

výchozí hodnota: True
_service_endpoint
str

Koncový bod služby.

výchozí hodnota: None

Návraty

Typ Description

Seznam objektů PublishedPipeline.

get_graph

Získejte graf publikovanéhopipeline.

get_graph(_workflow_provider=None)

Parametry

Name Description
_workflow_provider
<xref:azureml.pipeline.core._aeva_provider._AevaWorkflowProvider>

Poskytovatel pracovního postupu.

výchozí hodnota: None

Návraty

Typ Description

Graf.

get_step_names

Seznam názvů kroků získáte v části PublishedPipeline.

get_step_names(_workflow_provider=None)

Parametry

Name Description
_workflow_provider
<xref:azureml.pipeline.core._aeva_provider._AevaWorkflowProvider>

Poskytovatel pracovního postupu.

výchozí hodnota: None

Návraty

Typ Description

Seznam názvů kroků v části PublishedPipeline.

list

Získejte všechny publikované kanály v aktuálním pracovním prostoru.

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

Parametry

Name Description
workspace
Vyžadováno

Pracovní prostor, ve které byl publikovaný kanál vytvořen.

active_only

Jestli se mají vracet jenom publikované kanály, které jsou aktuálně aktivní.

výchozí hodnota: True
_service_endpoint
str

Koncový bod služby.

výchozí hodnota: None

Návraty

Typ Description

Seznam objektů PublishedPipeline.

save

Uložte YAML kanálu do souboru.

V současné době se pro export YAML podporují pouze kanály, které se skládají z moduleSteps.

save(path=None, _workflow_provider=None)

Parametry

Name Description
path
str

Cesta k uložení YAML do. Pokud je cesta adresář, soubor YAML kanálu se uloží na path/pipeline_name.yml. Pokud je cesta Žádná, použije se aktuální adresář.

výchozí hodnota: None
_workflow_provider
<xref:azureml.pipeline.core._aeva_provider._AevaWorkflowProvider>

Poskytovatel pracovního postupu.

výchozí hodnota: None

Návraty

Typ Description

submit

Odešlete publikovaný kanál. Jedná se o ekvivalent použití submit.

Vrátí odeslanou PipelineRunhodnotu . Tento objekt slouží k monitorování a zobrazení podrobností spuštění.

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

Parametry

Name Description
workspace
Vyžadováno

Pracovní prostor, do který chcete publikovaný kanál odeslat.

experiment_name
Vyžadováno
str

Název experimentu, do který se má odeslat.

pipeline_parameters

Slovník parametrů pro přiřazení nových hodnot {název_parametru, hodnota parametru}. Další podrobnosti najdete PipelineParameter v tématu.

výchozí hodnota: None
_workflow_provider
<xref:azureml.pipeline.core._aeva_provider._AevaWorkflowProvider>

Poskytovatel pracovního postupu.

výchozí hodnota: None
_service_endpoint
str

Koncový bod služby.

výchozí hodnota: None
parent_run_id
str

Volitelné ID spuštění, které se má nastavit pro nadřazené spuštění tohoto spuštění kanálu, které se projeví v runHistory. Nadřazené spuštění musí patřit do stejného experimentu, do kterého se tento kanál odesílá.

výchozí hodnota: None
continue_on_step_failure

Volitelné informace o tom, jestli chcete pokračovat v provádění dalších kroků v části PipelineSpustit v případě selhání kroku. Pokud ho zadáte, přepíše nastavení v kanálu.

výchozí hodnota: None

Návraty

Typ Description

Odeslaný kanál se spustí.

Atributy

continue_on_step_failure

Získejte hodnotu continue_on_step_failure nastavení.

Návraty

Typ Description

Hodnota continue_on_step_failure nastavení.

description

Získejte popis publikovaného kanálu.

Návraty

Typ Description
str

Popis publikovaného kanálu.

endpoint

Získejte adresu URL koncového bodu REST pro spuštění publikovaného kanálu.

Návraty

Typ Description
str

Adresa URL koncového bodu REST pro spuštění publikovaného kanálu

graph_id

Získejte ID grafu pro tento publikovaný kanál.

Návraty

Typ Description
str

ID grafu.

id

Získejte ID publikovaného kanálu.

Návraty

Typ Description
str

ID publikovaného kanálu.

name

Získejte název publikovaného kanálu.

Návraty

Typ Description
str

Název publikovaného kanálu.

status

Získejte stav publikovaného kanálu.

Návraty

Typ Description
str

Stav publikovaného kanálu.

total_run_steps

Získejte počet kroků v kanálu.

Návraty

Typ Description
int

Počet kroků v kanálu

version

Získejte verzi publikovaného kanálu.

Návraty

Typ Description
str

Verze publikovaného kanálu.