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ő
|
A közzétett folyamat neve. |
|
graph_id
Kötelező
|
A közzétett folyamat gráfjának azonosítója. |
|
description
Kötelező
|
A közzétett folyamat leírása. |
|
version
Kötelező
|
A közzétett folyamat verziója. |
|
published_pipeline_id
Kötelező
|
A közzétett folyamat azonosítója. |
|
status
Kötelező
|
A közzétett folyamat állapota ('Aktív' vagy 'Letiltva'). |
|
endpoint
Kötelező
|
A folyamat futtatásának elküldéséhez szükséges REST-végpont URL-címe. |
|
total_run_steps
Kötelező
|
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ő
|
A közzétett folyamat neve. |
|
graph_id
Kötelező
|
A közzétett folyamat gráfjának azonosítója. |
|
description
Kötelező
|
A közzétett folyamat leírása. |
|
version
Kötelező
|
A közzétett folyamat verziója. |
|
published_pipeline_id
Kötelező
|
A közzétett folyamat azonosítója. |
|
status
Kötelező
|
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ő
|
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
|
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
|
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
|
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
|
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ő
|
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
|
A szolgáltatásvégpont. Alapértelmezett érték: None
|
|
parent_run_id
|
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 |
description
A közzétett folyamat leírásának lekérése.
Válaszok
| Típus | Description |
|---|---|
|
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 |
|---|---|
|
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 |
|---|---|
|
A gráf azonosítója. |
id
Kérje le a közzétett folyamatazonosítót.
Válaszok
| Típus | Description |
|---|---|
|
A közzétett folyamat azonosítója. |
name
status
A közzétett folyamat állapotának lekérése.
Válaszok
| Típus | Description |
|---|---|
|
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 |
|---|---|
|
A folyamat lépéseinek száma. |
version
A közzétett folyamat verziójának lekérése.
Válaszok
| Típus | Description |
|---|---|
|
A közzétett folyamat verziója. |