Sdílet prostřednictvím


PublishedPipeline Třída

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

Kromě toho lze k opětovnému odeslání Pipeline souboru s různými PipelineParameter hodnotami a vstupy použít PublishedPipeline.

Inicializace PublishedPipeline.

:p aram koncový bod 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 pokračovat v provádění dalších kroků ve spuštění kanálu

Pokud krok selže, 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 z objektu PipelinePipelineRunnebo .

Příklad publikování z kanálu:


   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)

Pokud chcete publikovat z PipelineRunu, 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 Nepravda, což znamená, že když jeden krok selže, spuštění kanálu se zastaví a zruší se všechny spuštěné kroky.

Odešlete PublishedPipeline pomocí submit. Při volání odeslání 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 několik volitelných nastavení. Tady jsou některé z nich:

  • continue_on_step_failure: Volitelné, jestli chcete pokračovat v provádění dalších kroků v části PipelineSpustit 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í pro nastavení nadřazeného spuštění tohoto spuštění kanálu, což se projeví v 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í 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,
                                    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 například spravovanou opakovatelnost ve scénářích dávkového bodová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. To odpovídá použití submit.

Vrátí odeslanou PipelineRunhodnotu . Tento objekt slouží k monitorování a zobrazení podrobností o 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.

Default value: None
_service_endpoint
str

Koncový bod služby.

Default value: 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í.

Default value: True
_service_endpoint
str

Koncový bod služby.

Default value: 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.

Default value: 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.

Default value: 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í.

Default value: True
_service_endpoint
str

Koncový bod služby.

Default value: 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ář.

Default value: None
_workflow_provider
<xref:azureml.pipeline.core._aeva_provider._AevaWorkflowProvider>

Poskytovatel pracovního postupu.

Default value: None

Návraty

Typ Description

submit

Odešlete publikovaný kanál. To odpovídá použití submit.

Vrátí odeslanou PipelineRunhodnotu . Tento objekt slouží k monitorování a zobrazení podrobností o 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.

Default value: None
_workflow_provider
<xref:azureml.pipeline.core._aeva_provider._AevaWorkflowProvider>

Poskytovatel pracovního postupu.

Default value: None
_service_endpoint
str

Koncový bod služby.

Default value: 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á.

Default value: None
continue_on_step_failure

Jestli chcete pokračovat v provádění dalších kroků v části PipelineSpustit, pokud se krok nezdaří, volitelné. Pokud je k dispozici, přepíše nastavení v kanálu.

Default value: 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.