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.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 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
|
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. 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
|
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
|
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 |
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 |