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
- continue_on_step_failure
- bool
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
- <xref:azureml.pipeline.core._workflow_provider._PublishedPipelineProvider>
Publikovaný poskytovatel kanálu.
- _pipeline_provider
- <xref:azureml.pipeline.core._workflow_provider._PublishedPipelineProvider>
Publikovaný poskytovatel kanálu.
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
- _workflow_provider
- <xref:azureml.pipeline.core._aeva_provider._AevaWorkflowProvider>
Poskytovatel pracovního postupu.
Návraty
Objekt PublishedPipeline.
Návratový typ
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
- active_only
- bool
Jestli se mají vracet jenom publikované kanály, které jsou aktuálně aktivní.
Návraty
Seznam objektů PublishedPipeline.
Návratový typ
get_graph
Získejte graf publikovanéhopipeline.
get_graph(_workflow_provider=None)Parametry
- _workflow_provider
- <xref:azureml.pipeline.core._aeva_provider._AevaWorkflowProvider>
Poskytovatel pracovního postupu.
Návraty
Graf.
Návratový typ
get_step_names
Seznam názvů kroků získáte v části PublishedPipeline.
get_step_names(_workflow_provider=None)Parametry
- _workflow_provider
- <xref:azureml.pipeline.core._aeva_provider._AevaWorkflowProvider>
Poskytovatel pracovního postupu.
Návraty
Seznam názvů kroků v části PublishedPipeline.
Návratový typ
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
- active_only
- bool
Jestli se mají vracet jenom publikované kanály, které jsou aktuálně aktivní.
Návraty
Seznam objektů PublishedPipeline.
Návratový typ
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
- 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ář.
- _workflow_provider
- <xref:azureml.pipeline.core._aeva_provider._AevaWorkflowProvider>
Poskytovatel pracovního postupu.
Návratový typ
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
- pipeline_parameters
- dict
Slovník parametrů pro přiřazení nových hodnot {název_parametru, hodnota parametru}. Další podrobnosti najdete PipelineParameter v tématu.
- _workflow_provider
- <xref:azureml.pipeline.core._aeva_provider._AevaWorkflowProvider>
Poskytovatel pracovního postupu.
- 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á.
- continue_on_step_failure
- bool
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.
Návraty
Odeslaný kanál se spustí.
Návratový typ
Atributy
continue_on_step_failure
Získejte hodnotu continue_on_step_failure nastavení.
Návraty
Hodnota continue_on_step_failure nastavení.
Návratový typ
description
endpoint
Získejte adresu URL koncového bodu REST pro spuštění publikovaného kanálu.
Návraty
Adresa URL koncového bodu REST pro spuštění publikovaného kanálu
Návratový typ
graph_id
id
name
status
total_run_steps
version
Váš názor
Připravujeme: V průběhu roku 2024 budeme postupně vyřazovat problémy z GitHub coby mechanismus zpětné vazby pro obsah a nahrazovat ho novým systémem zpětné vazby. Další informace naleznete v tématu: https://aka.ms/ContentUserFeedback.
Odeslat a zobrazit názory pro