PublishedPipeline Třída

  • Reference

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.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
str
Vyžadováno

Název publikovaného kanálu.

graph_id
str
Vyžadováno

ID grafu pro tento publikovaný kanál.

description
str
Vyžadováno

Popis publikovaného kanálu.

version
str
Vyžadováno

Publikovaná verze kanálu.

published_pipeline_id
str
Vyžadováno

ID publikovaného kanálu.

status
str
Vyžadováno

Stav publikovaného kanálu (Aktivní nebo Zakázáno).

endpoint
str
Vyžadováno

Adresa URL koncového bodu REST pro odeslání se spustí pro tento kanál.

total_run_steps
int
Vyžadováno

Počet kroků v tomto kanálu

workspace
Workspace
Vyžadováno

Pracovní prostor publikovaného kanálu.

continue_on_step_failure
bool
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
<xref:azureml.pipeline.core._workflow_provider._PublishedPipelineProvider>
Vyžadováno

Publikovaný poskytovatel kanálu.

kwargs
dict
Vyžadováno

Argumenty vlastních klíčových slov vyhrazené pro budoucí vývoj

name
str
Vyžadováno

Název publikovaného kanálu.

graph_id
str
Vyžadováno

ID grafu pro tento publikovaný kanál.

description
str
Vyžadováno

Popis publikovaného kanálu.

version
str
Vyžadováno

Publikovaná verze kanálu.

published_pipeline_id
str
Vyžadováno

ID publikovaného kanálu.

status
str
Vyžadováno

Stav publikovaného kanálu (Aktivní nebo Zakázáno).

_pipeline_provider
<xref:azureml.pipeline.core._workflow_provider._PublishedPipelineProvider>
Vyžadováno

Publikovaný poskytovatel kanálu.

kwargs
dict
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

workspace
Workspace
Vyžadováno

Pracovní prostor, ve které byl publikovaný kanál vytvořen.

id
str
Vyžadováno

ID publikovaného kanálu.

_workflow_provider
<xref:azureml.pipeline.core._aeva_provider._AevaWorkflowProvider>
výchozí hodnota: None

Poskytovatel pracovního postupu.

_service_endpoint
str
výchozí hodnota: None

Koncový bod služby.

Návraty

Objekt PublishedPipeline.

Návratový typ

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

workspace
Workspace
Vyžadováno

Pracovní prostor, ve které byl publikovaný kanál vytvořen.

active_only
bool
výchozí hodnota: True

Jestli se mají vracet jenom publikované kanály, které jsou aktuálně aktivní.

_service_endpoint
str
výchozí hodnota: None

Koncový bod služby.

Návraty

Seznam objektů PublishedPipeline.

Návratový typ

list[PublishedPipeline]

get_graph

Získejte graf publikovanéhopipeline.

get_graph(_workflow_provider=None)

Parametry

_workflow_provider
<xref:azureml.pipeline.core._aeva_provider._AevaWorkflowProvider>
výchozí hodnota: None

Poskytovatel pracovního postupu.

Návraty

Graf.

Návratový typ

Graph

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>
výchozí hodnota: None

Poskytovatel pracovního postupu.

Návraty

Seznam názvů kroků v části PublishedPipeline.

Návratový typ

List[str]

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

workspace
Workspace
Vyžadováno

Pracovní prostor, ve které byl publikovaný kanál vytvořen.

active_only
bool
výchozí hodnota: True

Jestli se mají vracet jenom publikované kanály, které jsou aktuálně aktivní.

_service_endpoint
str
výchozí hodnota: None

Koncový bod služby.

Návraty

Seznam objektů PublishedPipeline.

Návratový typ

list[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

path
str
výchozí hodnota: None

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>
výchozí hodnota: None

Poskytovatel pracovního postupu.

Návratový typ

None

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

workspace
Workspace
Vyžadováno

Pracovní prostor, do který chcete publikovaný kanál odeslat.

experiment_name
str
Vyžadováno

Název experimentu, do který se má odeslat.

pipeline_parameters
dict
výchozí hodnota: None

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>
výchozí hodnota: None

Poskytovatel pracovního postupu.

_service_endpoint
str
výchozí hodnota: None

Koncový bod služby.

parent_run_id
str
výchozí hodnota: None

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
výchozí hodnota: None

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.

Návraty

Odeslaný kanál se spustí.

Návratový typ

PipelineRun

Atributy

continue_on_step_failure

Získejte hodnotu continue_on_step_failure nastavení.

Návraty

Hodnota continue_on_step_failure nastavení.

Návratový typ

bool

description

Získejte popis publikovaného kanálu.

Návraty

Popis publikovaného kanálu.

Návratový typ

str

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

str

graph_id

Získejte ID grafu pro tento publikovaný kanál.

Návraty

ID grafu.

Návratový typ

str

id

Získejte ID publikovaného kanálu.

Návraty

ID publikovaného kanálu.

Návratový typ

str

name

Získejte název publikovaného kanálu.

Návraty

Název publikovaného kanálu.

Návratový typ

str

status

Získejte stav publikovaného kanálu.

Návraty

Stav publikovaného kanálu.

Návratový typ

str

total_run_steps

Získejte počet kroků v kanálu.

Návraty

Počet kroků v kanálu

Návratový typ

int

version

Získejte verzi publikovaného kanálu.

Návraty

Verze publikovaného kanálu.

Návratový typ

str