Share via


PipelineEndpoint Klass

Representerar ett Pipeline arbetsflöde som kan utlösas från en unik slutpunkts-URL.

PipelineEndpoints kan användas för att skapa nya versioner av en PublishedPipeline samtidigt som samma slutpunkt bibehålls. PipelineEndpoints namnges unikt på en arbetsyta.

Med hjälp av slutpunktsattributet för ett PipelineEndpoint-objekt kan du utlösa nya pipelinekörningar från externa program med REST-anrop. Information om hur du autentiserar när du anropar REST-slutpunkter finns i https://aka.ms/pl-restep-auth.

Mer information om hur du skapar och kör maskininlärningspipelines finns i https://aka.ms/pl-first-pipeline.

Initiera PipelineEndpoint.

Arv
builtins.object
PipelineEndpoint

Konstruktor

PipelineEndpoint(workspace, id, name, description, status, default_version, endpoint, pipeline_version_list, _pipeline_endpoint_provider=None, _published_pipeline_provider=None, _swaggerurl=None)

Parametrar

workspace
Workspace
Obligatorisk

Arbetsytan PipelineEndpoint definieras i.

id
str
Obligatorisk

ID för PipelineEndpoint.

name
str
Obligatorisk

Namnet på PipelineEndpoint.

description
str
Obligatorisk

Beskrivningen av PipelineEndpoint.

status
str
Obligatorisk

Den nya statusen för PipelineEndpoint: "Aktiv" eller "Inaktiverad".

default_version
str
Obligatorisk

Standardversionen av pipelinen i PipelineEndpoint, automatisk ökning, börjar med "0".

endpoint
str
Obligatorisk

REST-slutpunkts-URL:en för PipelineEndpoint, som kan användas för att skicka pipelinekörningar.

pipeline_version_list
list
Obligatorisk

Listan över PipelineIdVersion objekt.

_pipeline_endpoint_provider
<xref:azureml.pipeline.core._aeva_provider._AevaPublishedPipelineProvider>
Obligatorisk

PipelineEndpoint-providern.

_pipeline_endpoint_provider
Obligatorisk

PublishedPipeline-providern.

workspace
Workspace
Obligatorisk

Arbetsyteobjektet som PipelineEndpoint kommer att tillhöra.

id
str
Obligatorisk

ID för PipelineEndpoint.

name
str
Obligatorisk

Namnet på PipelineEndpoint.

description
str
Obligatorisk

Beskrivningen av PipelineEndpoint.

status
str
Obligatorisk

Den nya statusen för PipelineEndpoint: "Aktiv" eller "Inaktiverad".

default_version
str
Obligatorisk

Standardversionen av pipelinen i PipelineEndpoint, automatisk ökning, börjar med "0"

endpoint
str
Obligatorisk

REST-slutpunkts-URL:en för PipelineEndpoint för att skicka pipelinekörningar.

pipeline_version_list
list
Obligatorisk

Listan över PipelineIdVersion

_pipeline_endpoint_provider
<xref:azureml.pipeline.core._aeva_provider._AevaPublishedPipelineProvider>
Obligatorisk

PipelineEndpoint-providern.

_pipeline_endpoint_provider
Obligatorisk

PublishedPipeline-providern.

swaggerendpoint
Obligatorisk

Swagger REST-slutpunkts-URL:en för PipelineEndpoint för att skicka pipelinekörningar.

Kommentarer

En PipelineEndpoint kan skapas från antingen en Pipeline eller en PublishedPipeline.

Ett exempel på publicering från en pipeline eller PublishedPipeline är följande:


   from azureml.pipeline.core import PipelineEndpoint

   # The pipeline argument can be either a Pipeline or a PublishedPipeline
   pipeline_endpoint = PipelineEndpoint.publish(workspace=ws,
                                                name="PipelineEndpointName",
                                                pipeline=pipeline,
                                                description="New Pipeline Endpoint")

Skicka en PipelineEndpoint med .submit När skicka anropas skapas en PipelineRun som i sin tur skapar StepRun objekt för varje steg i arbetsflödet.

Ett exempel på hur du skickar en PipelineEndpoint är följande:


   from azureml.pipeline.core import PipelineEndpoint

   pipeline_endpoint = PipelineEndpoint.get(workspace=ws, name="PipelineEndpointName")
   pipeline_run = experiment.submit(pipeline_endpoint)

Det finns ett antal valfria inställningar som kan anges när du skickar en PipelineEndpoint. Dessa omfattar:

  • pipeline_parameters: Parametrar för pipelinekörning, ordlista med {name: value}. Mer PipelineParameter information finns i.

  • parent_run_id: Du kan ange ett körnings-ID för att ange den överordnade körningen av den här pipelinekörningen, vilket visas i RunHistory. Den överordnade körningen måste tillhöra samma experiment som den som pipelinen skickas till.

  • pipeline_version: Pipelineversionen som ska köras.

Ett exempel på hur du skickar en PipelineEndpoint med de här inställningarna är följande:


   from azureml.pipeline.core import PipelineEndpoint

   pipeline_endpoint = PipelineEndpoint.get(workspace=ws, name="PipelineEndpointName")
   pipeline_run = experiment.submit(pipeline_endpoint,
                                    pipeline_parameters={"param1": "value1"},
                                    parent_run_id="<run_id>",
                                    pipeline_version="0")

Så här lägger du till en ny version av en PipelineEndpoint-användning:


   from azureml.pipeline.core import PipelineEndpoint

   pipeline_endpoint = PipelineEndpoint.get(workspace=ws, name="PipelineEndpointName")
   pipeline_endpoint.add(published_pipeline)

Mer information om hur du skapar och använder PipelineEndpoints finns i följande notebook-fil: https://aka.ms/pl-ver-endpoint.

Metoder

add

Lägg till den angivna pipelinen i PipelineEndpoint.

add_default

Lägg till den angivna pipelinen i PipelineEndpoint och ange standardversionen till den tillagda pipelineversionen.

archive

Arkivera PipelineEndpoint.

disable

Ange PipelineEndpoint till "Inaktiverad" och otillgänglig att köra.

enable

Ange PipelineEndpoint till "Aktiv" och tillgänglig för körning.

get

Hämta PipelineEndpoint efter namn eller ID, genererar undantag om någon av dem inte har angetts.

get_all

Hämta alla aktiva PipelineEndpoints i den aktuella arbetsytan.

Hämta alla aktiva PipelineEndpoints. Obs! Den här metoden håller på att bli inaktuell till förmån för PipelineEndpoint.list().

get_all_pipelines

Hämta en lista över pipelines i PipelineEndpoint.

Obs! Den här metoden är inaktuell till förmån för list_pipelines()

get_all_versions

Hämta en lista över pipelines och motsvarande versioner i PipelineEndpoint.

Obs! Den här metoden är inaktuell till förmån för list_versions()

get_default_version

Hämta standardversionen av PipelineEndpoint.

get_pipeline

Hämta pipelinen för en angiven version eller standard. genererar ett undantag om versionen inte hittas.

list

Visa en lista över aktiva PipelineEndpoints i den aktuella arbetsytan.

list_pipelines

Hämta en lista över pipelines som är associerade med PipelineEndpoint.

list_versions

Hämta en lista över pipelines och motsvarande versioner av PipelineEndpoint.

publish

Skapa en PipelineEndpoint med det angivna namnet och pipelinen/den publicerade pipelinen.

Pipelineslutpunkten är ett REST-API som kan användas från externa program. Information om hur du autentiserar när du anropar REST-slutpunkter finns i https://aka.ms/pl-restep-auth.

Mer information om hur du arbetar med pipelineslutpunkter finns i https://aka.ms/pl-first-pipeline.

Genererar undantag om det redan finns en PipelineEndpoint med det angivna namnet.

reactivate

Återaktivera en PipelineEndpoint som arkiverades.

set_default

Ange standardversionen av PipelineEndpoint och utlöser ett undantag om den angivna pipelinen inte hittas.

set_default_version

Ange standardversionen av PipelineEndpoint och utlöser ett undantag om den angivna versionen inte hittas.

set_name

Ange namnet på PipelineEndpoint.

submit

Skicka ett pipelineexperiment av den angivna versionen; om versionen inte är någon utlöser standardversionen av pipelinen.

add

Lägg till den angivna pipelinen i PipelineEndpoint.

add(pipeline)

Parametrar

pipeline
PublishedPipeline
Obligatorisk

En publicerad pipeline att lägga till.

add_default

Lägg till den angivna pipelinen i PipelineEndpoint och ange standardversionen till den tillagda pipelineversionen.

add_default(pipeline)

Parametrar

pipeline
PublishedPipeline
Obligatorisk

En publicerad pipeline som ska läggas till som standardversion.

archive

Arkivera PipelineEndpoint.

archive()

disable

Ange PipelineEndpoint till "Inaktiverad" och otillgänglig att köra.

disable()

enable

Ange PipelineEndpoint till "Aktiv" och tillgänglig för körning.

enable()

get

Hämta PipelineEndpoint efter namn eller ID, genererar undantag om någon av dem inte har angetts.

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

Parametrar

workspace
Workspace
Obligatorisk

Arbetsytan pipelineEndpoint skapades i.

id
str
standardvärde: None

ID för PipelineEndpoint.

name
str
standardvärde: None

Namnet på PipelineEndpoint.

_workflow_provider
<xref:azureml.pipeline.core._aeva_provider._AevaWorkflowProvider>
standardvärde: None

Arbetsflödesprovidern.

_service_endpoint
str
standardvärde: None

Tjänstslutpunkten.

Returer

PipelineEndpoint-objektet.

Returtyp

get_all

Hämta alla aktiva PipelineEndpoints i den aktuella arbetsytan.

Hämta alla aktiva PipelineEndpoints. Obs! Den här metoden håller på att bli inaktuell till förmån för PipelineEndpoint.list().

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

Parametrar

workspace
Workspace
Obligatorisk

Arbetsytan.

active_only
bool
standardvärde: True

Om det är sant returnerar du endast PipelineEndpoints som för närvarande är aktiva.

_workflow_provider
<xref:azureml.pipeline.core._aeva_provider._AevaWorkflowProvider>
standardvärde: None

Arbetsflödesprovidern.

_service_endpoint
str
standardvärde: None

Tjänstslutpunkten.

Returer

Listan över PipelineEndpoint objekt.

Returtyp

get_all_pipelines

Hämta en lista över pipelines i PipelineEndpoint.

Obs! Den här metoden är inaktuell till förmån för list_pipelines()

get_all_pipelines(active_only=True, _workflow_provider=None, _service_endpoint=None)

Parametrar

active_only
bool
standardvärde: True

Flagga för att endast returnera aktiva pipelines.

_workflow_provider
<xref:azureml.pipeline.core._aeva_provider._AevaWorkflowProvider>
standardvärde: None

Arbetsflödesprovidern.

_service_endpoint
str
standardvärde: None

Tjänstslutpunkten.

Returer

Listan över PublishedPipeline objekt.

Returtyp

get_all_versions

Hämta en lista över pipelines och motsvarande versioner i PipelineEndpoint.

Obs! Den här metoden är inaktuell till förmån för list_versions()

get_all_versions(_workflow_provider=None, _service_endpoint=None)

Parametrar

_workflow_provider
<xref:azureml.pipeline.core._aeva_provider._AevaWorkflowProvider>
standardvärde: None

Arbetsflödesprovidern.

_service_endpoint
str
standardvärde: None

Tjänstslutpunkten.

Returer

Listan över PipelineVersion objekt.

Returtyp

get_default_version

Hämta standardversionen av PipelineEndpoint.

get_default_version()

Returer

Standardversionen av pipelineslutpunkten.

Returtyp

str

get_pipeline

Hämta pipelinen för en angiven version eller standard. genererar ett undantag om versionen inte hittas.

get_pipeline(version=None)

Parametrar

version
str
standardvärde: None

Den version av pipelinen som ska returneras.

Returer

En publicerad pipeline.

Returtyp

list

Visa en lista över aktiva PipelineEndpoints i den aktuella arbetsytan.

static list(workspace, active_only=True, max_results=100, _workflow_provider=None, _service_endpoint=None)

Parametrar

workspace
Workspace
Obligatorisk

Arbetsytan.

active_only
bool
standardvärde: True

Om det är sant returnerar du endast PipelineEndpoints som för närvarande är aktiva.

max_results
int
standardvärde: 100

maximalt antal rader med returnerade PipelineEndpoints

_workflow_provider
<xref:azureml.pipeline.core._aeva_provider._AevaWorkflowProvider>
standardvärde: None

Arbetsflödesprovidern.

_service_endpoint
str
standardvärde: None

Tjänstslutpunkten.

Returer

Listan över PipelineEndpoint objekt.

Returtyp

list_pipelines

Hämta en lista över pipelines som är associerade med PipelineEndpoint.

list_pipelines(active_only=True, _workflow_provider=None, _service_endpoint=None)

Parametrar

active_only
bool
standardvärde: True

Anger om endast aktiva pipelines ska returneras.

_workflow_provider
<xref:azureml.pipeline.core._aeva_provider._AevaWorkflowProvider>
standardvärde: None

Arbetsflödesprovidern.

_service_endpoint
str
standardvärde: None

Tjänstslutpunkten.

Returer

Listan över PublishedPipeline objekt.

Returtyp

list_versions

Hämta en lista över pipelines och motsvarande versioner av PipelineEndpoint.

list_versions(_workflow_provider=None, _service_endpoint=None)

Parametrar

_workflow_provider
<xref:azureml.pipeline.core._aeva_provider._AevaWorkflowProvider>
standardvärde: None

Arbetsflödesprovidern.

_service_endpoint
str
standardvärde: None

Tjänstslutpunkten.

Returer

Listan över PipelineVersion objekt.

Returtyp

publish

Skapa en PipelineEndpoint med det angivna namnet och pipelinen/den publicerade pipelinen.

Pipelineslutpunkten är ett REST-API som kan användas från externa program. Information om hur du autentiserar när du anropar REST-slutpunkter finns i https://aka.ms/pl-restep-auth.

Mer information om hur du arbetar med pipelineslutpunkter finns i https://aka.ms/pl-first-pipeline.

Genererar undantag om det redan finns en PipelineEndpoint med det angivna namnet.

static publish(workspace, name, description, pipeline, _workflow_provider=None, _service_endpoint=None)

Parametrar

workspace
Workspace
Obligatorisk

Arbetsytan för att skapa PipelineEndpoint i.

name
str
Obligatorisk

Namnet på PipelineEndpoint.

description
str
Obligatorisk

Beskrivning av PipelineEndpoint.

pipeline
PublishedPipeline eller Pipeline
Obligatorisk

Den publicerade pipelinen eller pipelinen.

_service_endpoint
str
standardvärde: None

Tjänstslutpunkten.

_workflow_provider
<xref:azureml.pipeline.core._aeva_provider._AevaWorkflowProvider>
standardvärde: None

Arbetsflödesprovidern.

Returer

En ny PipelineEndpoint.

Returtyp

Undantag

reactivate

Återaktivera en PipelineEndpoint som arkiverades.

reactivate(name)

Parametrar

name
str
Obligatorisk

Namnet som ska anges.

Returer

Ett PipelineEndpoint-objekt.

Returtyp

set_default

Ange standardversionen av PipelineEndpoint och utlöser ett undantag om den angivna pipelinen inte hittas.

set_default(pipeline)

Parametrar

pipeline
PublishedPipeline
Obligatorisk

Den publicerade pipelinen som ska anges som standard.

Undantag

set_default_version

Ange standardversionen av PipelineEndpoint och utlöser ett undantag om den angivna versionen inte hittas.

set_default_version(version)

Parametrar

version
str
Obligatorisk

Den version som ska anges som standardversion i PipelineEndpoint.

Undantag

set_name

Ange namnet på PipelineEndpoint.

set_name(name)

Parametrar

name
str
Obligatorisk

Namnet som ska anges.

submit

Skicka ett pipelineexperiment av den angivna versionen; om versionen inte är någon utlöser standardversionen av pipelinen.

submit(experiment_name, pipeline_parameters=None, parent_run_id=None, pipeline_version=None)

Parametrar

experiment_name
str
Obligatorisk

Namnet på experimentet som pipelinen ska skickas in i.

pipeline_parameters
dict
standardvärde: None

Parametrar som ska användas vid pipelinekörning, som skickas som en ordlista med {name: value}. Mer PipelineParameter information finns i.

parent_run_id
str
standardvärde: None

Du kan ange ett körnings-ID för att ange den överordnade körningen av den här pipelinekörningen, vilket visas i RunHistory. Den överordnade körningen måste tillhöra samma experiment som den här pipelinen skickas till.

pipeline_version
str
standardvärde: None

Den version av pipelinen som ska köras.

Returer

Den skickade pipelinekörningen.

Returtyp

Undantag

Attribut

default_version

Hämta standardversionen av PipelineEndpoint.

Returer

Standardversionen.

Returtyp

str

description

Hämta beskrivningen av PipelineEndpoint.

Returer

Beskrivningen.

Returtyp

str

endpoint

Hämta REST-slutpunkts-URL:en för PipelineEndpoint.

Slutpunkten kan användas för att utlösa körningar av pipelinen.

Returer

REST-slutpunkt för PipelineEndpoint för att köra pipeline.

Returtyp

str

id

Hämta ID för PipelineEndpoint.

Returer

ID för PipelineEndpoint.

Returtyp

str

name

Hämta namnet på PipelineEndpoint.

Returer

Namnet.

Returtyp

str

pipeline_version_list

Hämta listan över pipelineversioner.

Returer

Listan över PipelineIdVersion objekt.

Returtyp

status

Hämta status för PipelineEndpoint.

Returer

Status.

Returtyp

str

swaggerurl

Hämta REST Swagger-URL:en för PipelineEndpoint.

Swagger-URL:en kan vara ett schema för pipelineslutpunkten.

Returer

REST Swagger för PipelineEndpoint för att köra pipeline.

Returtyp

str