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.HasPipelinePortalPublishedPipeline
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
|
Název publikovaného kanálu. |
graph_id
Vyžadováno
|
ID grafu pro tento publikovaný kanál. |
description
Vyžadováno
|
Popis publikovaného kanálu. |
version
Vyžadováno
|
Publikovaná verze kanálu. |
published_pipeline_id
Vyžadováno
|
ID publikovaného kanálu. |
status
Vyžadováno
|
Stav publikovaného kanálu (Aktivní nebo Zakázáno). |
endpoint
Vyžadováno
|
Adresa URL koncového bodu REST pro odeslání se spustí pro tento kanál. |
total_run_steps
Vyžadováno
|
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
|
Název publikovaného kanálu. |
graph_id
Vyžadováno
|
ID grafu pro tento publikovaný kanál. |
description
Vyžadováno
|
Popis publikovaného kanálu. |
version
Vyžadováno
|
Publikovaná verze kanálu. |
published_pipeline_id
Vyžadováno
|
ID publikovaného kanálu. |
status
Vyžadováno
|
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
|
ID publikovaného kanálu. |
_workflow_provider
|
<xref:azureml.pipeline.core._aeva_provider._AevaWorkflowProvider>
Poskytovatel pracovního postupu. Default value: None
|
_service_endpoint
|
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
|
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
|
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
|
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. 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
|
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
|
Koncový bod služby. Default value: None
|
parent_run_id
|
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
|
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. 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 |
description
endpoint
Získejte adresu URL koncového bodu REST pro spuštění publikovaného kanálu.
Návraty
Typ | Description |
---|---|
Adresa URL koncového bodu REST pro spuštění publikovaného kanálu |