PublishedPipeline Třída

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

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

Inicializace publishedPipeline

:p aaram koncový bod ADRESA URL koncového bodu REST pro odesílá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: Zda pokračovat v provádění dalších kroků v Spuštění kanálu

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

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, která odešle spuštění pro tento kanál.
total_run_steps Vyžadováno	int Početkrokůch
workspace Vyžadováno	Workspace Pracovní prostor publikovaného kanálu.
continue_on_step_failure Vyžadováno	bool Zda pokračovat v provádění dalších kroků v PipelineRun, pokud krok selže. Výchozí hodnota je false.
_pipeline_provider Vyžadováno	<xref:azureml.pipeline.core._workflow_provider._PublishedPipelineProvider> Poskytovatel publikovaného kanálu.
kwargs Vyžadováno	dict Vlastní argumenty 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> Poskytovatel publikovaného kanálu.
kwargs Vyžadováno	dict Vlastní argumenty klíčových slov, vyhrazené pro budoucí vývoj

Poznámky

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

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í 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 provádění kroků v kanálu bude pokračovat, pokud jeden krok selže. Výchozí hodnota je False, což znamená, že když jeden krok selže, spuštění kanálu se zastaví a zruší všechny spuštěné kroky.

Odešle publikovanoupipeline pomocí submit. Při volání odeslání se vytvoří PipelineRun objekty StepRun pro každý krok pracovního postupu.

Příklad odeslání publikovanéhopipeline 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í. Patří mezi ně:

continue_on_step_failure: Jestli chcete pokračovat v provádění dalších kroků v spuštění kanálu, pokud krok selže, volitelné. Pokračovat v provádění budou pouze kroky, které nemají žádnou závislost na výstupu neúspěšného kroku. Pokud je k dispozici, toto nastavení parametru přepíše nastavení kanálu.
pipeline_parameters: Parametry spuštění kanálu, slovník {name: value}. Další podrobnosti najdete v PipelineParameter.
parent_run_id: Můžete zadat ID spuštění pro nastavení nadřazeného spuštění tohoto spuštění kanálu, který se odráží v runHistory. Nadřazené spuštění musí patřit do stejného experimentu jako kanál, který se odesí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. S koncovým bodem kanálu můžete aktivovat spuštění kanálu z externích systémů, jako jsou klienti mimo Python. Informace o ověřování při volání koncovýchbodůch https://aka.ms/pl-restep-auth

Použití koncového bodu umožňuje "spravovanou opakovatelnost" ve scénářích dávkového bodování a opětovném natrénování, například. Další informace najdete v tématu https://aka.ms/pl-first-pipeline.

Metody

disable	Nastavte publikovaný kanál na Zakázáno a není možné ho spustit.
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	Získejte seznam názvů kroků v publikovanémpipeline.
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í jenom kanály, které se skládají z modulů ModuleStep.
submit	Odešlete publikovaný kanál. To je ekvivalent 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í možné ho spustit.

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	Workspace 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> Zprostředkovatel pracovního postupu. Default value: None
_service_endpoint	str Koncový bod služby. Default value: None

Návraty

Typ	Description
PublishedPipeline	A PublishedPipeline objekt.

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	Workspace Pracovní prostor, na který byl publikovaný kanál vytvořen.
active_only	bool Zda se mají vrátit pouze 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
list[PublishedPipeline]	Seznam PublikovanýPipeline objekty.

get_graph

Získejte graf publikovanéhopipeline.

get_graph(_workflow_provider=None)

Parametry

Name	Description
_workflow_provider	<xref:azureml.pipeline.core._aeva_provider._AevaWorkflowProvider> Zprostředkovatel pracovního postupu. Default value: None

Návraty

Typ	Description
Graph	Graf.

get_step_names

Získejte seznam názvů kroků v publikovanémpipeline.

get_step_names(_workflow_provider=None)

Parametry

Name	Description
_workflow_provider	<xref:azureml.pipeline.core._aeva_provider._AevaWorkflowProvider> Zprostředkovatel pracovního postupu. Default value: None

Návraty

Typ	Description
List[str]	Seznam názvů kroků v publikovanémpipeline.

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	Workspace Pracovní prostor, ve který byl publikovaný kanál vytvořen.
active_only	bool Zda se mají vrátit pouze 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
list[PublishedPipeline]	Seznam PublikovanýPipeline objekty.

save

Uložte YAML kanálu do souboru.

V současné době se pro export YAML podporují jenom kanály, které se skládají z modulů ModuleStep.

save(path=None, _workflow_provider=None)

Parametry

Name	Description
path	str Cesta k uložení YAML do. Pokud je cesta adresář, uloží se soubor YAML kanálu na cestě nebo pipeline_name.yml. Pokud cesta není Žádná, použije se aktuální adresář. Default value: None
_workflow_provider	<xref:azureml.pipeline.core._aeva_provider._AevaWorkflowProvider> Zprostředkovatel pracovního postupu. Default value: None

Návraty

Typ	Description
None

submit

Odešlete publikovaný kanál. To je ekvivalent 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	Workspace Pracovní prostor pro odeslání publikovaného kanálu.
experiment_name Vyžadováno	str Název experimentu, do který se má odeslat.
pipeline_parameters	dict Slovník parametrů pro přiřazení nových hodnot {název parametru, hodnota parametru}. Další podrobnosti najdete v PipelineParameter. Default value: None
_workflow_provider	<xref:azureml.pipeline.core._aeva_provider._AevaWorkflowProvider> Zprostředkovatel 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 nastaví pro nadřazené spuštění tohoto kanálu, což 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	bool Jestli chcete pokračovat v provádění dalších kroků v PipelineRunu, pokud se krok nezdaří, volitelné. V případě potřeby přepíše nastavení kanálu. Default value: None

Návraty

Typ	Description
PipelineRun	Odeslaná spuštění kanálu.

Atributy

continue_on_step_failure

Získá hodnotu continue_on_step_failure nastavení.

Návraty

Typ	Description
bool	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četkrokůch

version

Získejte verzi publikovaného kanálu.

Návraty

Typ	Description
str	Verze publikovaného kanálu.

Váš názor

Byla tato stránka užitečná?

Sdílet prostřednictvím

PublishedPipeline Třída

Konstruktor

Parametry

Poznámky

Metody

disable

enable

get

Parametry

Návraty

get_all

Parametry

Návraty

get_graph

Parametry

Návraty

get_step_names

Parametry

Návraty

list

Parametry

Návraty

save

Parametry

Návraty

submit

Parametry

Návraty

Atributy

continue_on_step_failure

Návraty

description

Návraty

endpoint

Návraty

graph_id

Návraty

id

Návraty

name

Návraty

status

Návraty

total_run_steps

Návraty

version

Návraty

Váš názor