Megosztás a következőn keresztül:


PublishedPipeline Osztály

Egy olyan folyamatot jelöl, amely a Python-kód nélkül küldhető el.

Emellett a PublishedPipeline más értékeket és bemeneteket tartalmazó Pipeline újraküldésére PipelineParameter is használható.

A PublishedPipeline inicializálása.

:p aram végpont: A folyamatfuttatások elküldéséhez szükséges REST-végpont URL-címe. :type endpoint: str :p aram total_run_steps: A folyamat lépéseinek száma :type total_run_steps: int :p aram workspace: A közzétett folyamat munkaterülete. :type workspace: azureml.core.Workspace :p aram continue_on_step_failure: További lépések végrehajtása a PipelineRunban

ha egy lépés meghiúsul, az alapértelmezett érték hamis.

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)

Paraméterek

Name Description
name
Kötelező
str

A közzétett folyamat neve.

graph_id
Kötelező
str

A közzétett folyamat gráfjának azonosítója.

description
Kötelező
str

A közzétett folyamat leírása.

version
Kötelező
str

A közzétett folyamat verziója.

published_pipeline_id
Kötelező
str

A közzétett folyamat azonosítója.

status
Kötelező
str

A közzétett folyamat állapota ('Aktív' vagy 'Letiltva').

endpoint
Kötelező
str

A folyamat futtatásának elküldéséhez szükséges REST-végpont URL-címe.

total_run_steps
Kötelező
int

A folyamat lépéseinek száma.

workspace
Kötelező

A közzétett folyamat munkaterülete.

continue_on_step_failure
Kötelező

Azt határozza meg, hogy folytatja-e a folyamatfuttatás más lépéseinek végrehajtását, ha egy lépés meghiúsul. Az alapértelmezett érték hamis.

_pipeline_provider
Kötelező
<xref:azureml.pipeline.core._workflow_provider._PublishedPipelineProvider>

A közzétett folyamatszolgáltató.

kwargs
Kötelező

Egyéni kulcsszóargumentumok, jövőbeli fejlesztéshez fenntartva

name
Kötelező
str

A közzétett folyamat neve.

graph_id
Kötelező
str

A közzétett folyamat gráfjának azonosítója.

description
Kötelező
str

A közzétett folyamat leírása.

version
Kötelező
str

A közzétett folyamat verziója.

published_pipeline_id
Kötelező
str

A közzétett folyamat azonosítója.

status
Kötelező
str

A közzétett folyamat állapota ('Aktív' vagy 'Letiltva').

_pipeline_provider
Kötelező
<xref:azureml.pipeline.core._workflow_provider._PublishedPipelineProvider>

A közzétett folyamatszolgáltató.

kwargs
Kötelező

Egyéni kulcsszóargumentumok, jövőbeli fejlesztéshez fenntartva

Megjegyzések

A PublishedPipeline egy vagy Pipelineegy PipelineRun .

Egy folyamatból való közzétételre példa a következő:


   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)

PipelineRun-ból való közzétételhez használja a következőt:


   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)

Megjegyzés: a continue_on_step_failure paraméter azt határozza meg, hogy a folyamat lépéseinek végrehajtása folytatódik-e, ha egy lépés meghiúsul. Az alapértelmezett érték Hamis, ami azt jelenti, hogy ha egy lépés meghiúsul, a folyamat végrehajtása leáll, és megszakítja a futó lépéseket.

PublishedPipeline küldése a következő használatával submit: . A küldés meghívásakor létrejön egy PipelineRun objektum, amely a munkafolyamat minden lépéséhez létrehoz StepRun objektumokat.

A PublishedPipeline elküldésére a következő példa látható:


   from azureml.pipeline.core import PublishedPipeline

   published_pipeline = PublishedPipeline.get(workspace=ws, id="published_pipeline_id")
   pipeline_run = experiment.submit(published_pipeline)

Számos választható beállítás adható meg a PublishedPipeline elküldésekor. Ezek a következők:

  • continue_on_step_failure: Nem kötelező, hogy a Folyamatfuttatás más lépéseinek végrehajtása is folytatódjon-e, ha egy lépés meghiúsul. Csak azok a lépések folytatódnak, amelyek nem függnek a sikertelen lépés kimenetétől. Ha meg van adva, ez a paraméterbeállítás felülbírálja a beállítást a folyamaton.

  • pipeline_parameters: A folyamat végrehajtásának paraméterei, a(z) {name: value} szótára. További részletekért lásd a PipelineParameter.

  • parent_run_id: Megadhat egy futtatási azonosítót a folyamatfuttatás szülőfuttatásának beállításához, amely a RunHistoryban is megjelenik. A szülőfuttatásnak ugyanahhoz a kísérlethez kell tartoznia, mint az elküldött folyamatnak.

A PublishedPipeline-nak az alábbi beállítások használatával történő elküldésére a következő példa látható:


   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>")

Minden közzétett folyamat rendelkezik REST-végpontokkal. A folyamatvégponttal elindíthatja a folyamat futtatását külső rendszerekből, például nem Python-ügyfelekről. További információ a REST-végpontok hívása során történő hitelesítésről: https://aka.ms/pl-restep-auth.

A végpont használata lehetővé teszi például a kötegelt pontozási és újratanítási forgatókönyvek "felügyelt megismételhetőségét". További információ: https://aka.ms/pl-first-pipeline.

Metódusok

disable

Állítsa a közzétett folyamatot "Letiltva" értékre, és nem futtatható.

enable

Állítsa a közzétett folyamatot "Aktív" értékre, és futtassa.

get

A közzétett folyamat lekérése.

get_all

Az összes közzétett folyamat lekérése az aktuális munkaterületen.

ELAVULT: Ez a metódus elavult a PublishedPipeline list metódus javára.

get_graph

A PublishedPipeline grafikonjának lekérése.

get_step_names

Kérje le a lépések nevének listáját a PublishedPipeline-ban.

list

Az összes közzétett folyamat lekérése az aktuális munkaterületen.

save

Mentse a folyamat YAML-ét egy fájlba.

Jelenleg csak a ModuleSteps-ekből álló folyamatok támogatottak a YAML-exportáláshoz.

submit

Küldje el a közzétett folyamatot. Ez egyenértékű a használattal submit.

A beküldött PipelineRunértéket adja vissza. Ezzel az objektummal figyelheti és tekintheti meg a futtatás részleteit.

disable

Állítsa a közzétett folyamatot "Letiltva" értékre, és nem futtatható.

disable()

enable

Állítsa a közzétett folyamatot "Aktív" értékre, és futtassa.

enable()

get

A közzétett folyamat lekérése.

static get(workspace, id, _workflow_provider=None, _service_endpoint=None)

Paraméterek

Name Description
workspace
Kötelező

A közzétett folyamat munkaterülete.

id
Kötelező
str

A közzétett folyamat azonosítója.

_workflow_provider
<xref:azureml.pipeline.core._aeva_provider._AevaWorkflowProvider>

A munkafolyamat-szolgáltató.

Alapértelmezett érték: None
_service_endpoint
str

A szolgáltatásvégpont.

Alapértelmezett érték: None

Válaszok

Típus Description

Egy PublishedPipeline objektum.

get_all

Az összes közzétett folyamat lekérése az aktuális munkaterületen.

ELAVULT: Ez a metódus elavult a PublishedPipeline list metódus javára.

static get_all(workspace, active_only=True, _service_endpoint=None)

Paraméterek

Name Description
workspace
Kötelező

Azon munkaterület, amelyen a közzétett folyamat létre lett hozva.

active_only

Azt határozza meg, hogy csak az aktuálisan aktív közzétett folyamatokat adja vissza.

Alapértelmezett érték: True
_service_endpoint
str

A szolgáltatásvégpont.

Alapértelmezett érték: None

Válaszok

Típus Description

A PublishedPipeline objektumok listája.

get_graph

A PublishedPipeline grafikonjának lekérése.

get_graph(_workflow_provider=None)

Paraméterek

Name Description
_workflow_provider
<xref:azureml.pipeline.core._aeva_provider._AevaWorkflowProvider>

A munkafolyamat-szolgáltató.

Alapértelmezett érték: None

Válaszok

Típus Description

A gráf.

get_step_names

Kérje le a lépések nevének listáját a PublishedPipeline-ban.

get_step_names(_workflow_provider=None)

Paraméterek

Name Description
_workflow_provider
<xref:azureml.pipeline.core._aeva_provider._AevaWorkflowProvider>

A munkafolyamat-szolgáltató.

Alapértelmezett érték: None

Válaszok

Típus Description

A PublishedPipeline lépéseinek listája.

list

Az összes közzétett folyamat lekérése az aktuális munkaterületen.

static list(workspace, active_only=True, _service_endpoint=None)

Paraméterek

Name Description
workspace
Kötelező

A közzétett folyamat munkaterülete.

active_only

Azt határozza meg, hogy csak az aktuálisan aktív közzétett folyamatokat adja vissza.

Alapértelmezett érték: True
_service_endpoint
str

A szolgáltatásvégpont.

Alapértelmezett érték: None

Válaszok

Típus Description

A PublishedPipeline objektumok listája.

save

Mentse a folyamat YAML-ét egy fájlba.

Jelenleg csak a ModuleSteps-ekből álló folyamatok támogatottak a YAML-exportáláshoz.

save(path=None, _workflow_provider=None)

Paraméterek

Name Description
path
str

A YAML mentési útvonala. Ha az elérési út könyvtár, a folyamat YAML-fájlja az elérési út/pipeline_name.yml lesz mentve. Ha az elérési út Nincs, a rendszer az aktuális könyvtárat használja.

Alapértelmezett érték: None
_workflow_provider
<xref:azureml.pipeline.core._aeva_provider._AevaWorkflowProvider>

A munkafolyamat-szolgáltató.

Alapértelmezett érték: None

Válaszok

Típus Description

submit

Küldje el a közzétett folyamatot. Ez egyenértékű a használattal submit.

A beküldött PipelineRunértéket adja vissza. Ezzel az objektummal figyelheti és tekintheti meg a futtatás részleteit.

submit(workspace, experiment_name, pipeline_parameters=None, _workflow_provider=None, _service_endpoint=None, parent_run_id=None, continue_on_step_failure=None)

Paraméterek

Name Description
workspace
Kötelező

A közzétett folyamatot beküldő munkaterület.

experiment_name
Kötelező
str

Annak a kísérletnek a neve, amelybe be szeretne küldeni.

pipeline_parameters

Paraméterek szótára új értékek hozzárendeléséhez {param name, param value}. További részletekért lásd a PipelineParameter.

Alapértelmezett érték: None
_workflow_provider
<xref:azureml.pipeline.core._aeva_provider._AevaWorkflowProvider>

A munkafolyamat-szolgáltató.

Alapértelmezett érték: None
_service_endpoint
str

A szolgáltatásvégpont.

Alapértelmezett érték: None
parent_run_id
str

A folyamatfuttatás szülőfuttatásának beállításához választható futtatási azonosító, amely a RunHistoryban is megjelenik. A szülőfuttatásnak ugyanahhoz a kísérlethez kell tartoznia, mint a folyamatnak.

Alapértelmezett érték: None
continue_on_step_failure

Nem kötelező, hogy egy lépés meghiúsulása esetén folytatódjon-e a Folyamatfuttatás más lépéseinek végrehajtása. Ha meg van adva, felülbírálja a beállítást a folyamaton.

Alapértelmezett érték: None

Válaszok

Típus Description

Az elküldött folyamat futtatása.

Attribútumok

continue_on_step_failure

A beállítás értékének lekérése continue_on_step_failure .

Válaszok

Típus Description

A beállítás értéke continue_on_step_failure .

description

A közzétett folyamat leírásának lekérése.

Válaszok

Típus Description
str

A közzétett folyamat leírása.

endpoint

Kérje le a REST-végpont URL-címét egy közzétett folyamat futtatásához.

Válaszok

Típus Description
str

A közzétett folyamat futtatásához használt REST-végpont URL-címe.

graph_id

Kérje le a közzétett folyamat gráfjának azonosítóját.

Válaszok

Típus Description
str

A gráf azonosítója.

id

Kérje le a közzétett folyamatazonosítót.

Válaszok

Típus Description
str

A közzétett folyamat azonosítója.

name

Kérje le a közzétett folyamat nevét.

Válaszok

Típus Description
str

A közzétett folyamat neve.

status

A közzétett folyamat állapotának lekérése.

Válaszok

Típus Description
str

A közzétett folyamat állapota.

total_run_steps

A folyamat lépéseinek számának lekérése.

Válaszok

Típus Description
int

A folyamat lépéseinek száma.

version

A közzétett folyamat verziójának lekérése.

Válaszok

Típus Description
str

A közzétett folyamat verziója.