PublishedPipeline Sınıf

Bunu oluşturan Python kodu olmadan gönderilecek işlem hattını temsil eder.

Buna ek olarak, bir PublishedPipeline farklı PipelineParameter değerler ve girişlerle yeniden Pipeline göndermek için kullanılabilir.

PublishedPipeline'i başlatın.

:p aram uç noktası Bu işlem hattı için işlem hattı çalıştırmalarını göndermek için REST uç nokta URL'si. :type endpoint: str :p aram total_run_steps: Bu işlem hattındaki adımların sayısı: total_run_steps yazın: int :p aram çalışma alanı: Yayımlanan işlem hattının çalışma alanı. :type workspace: azureml.core.Workspace :p aram continue_on_step_failure: PipelineRun'da diğer adımların yürütülmesine devam edilip edilmeyeceği

Bir adım başarısız olursa, varsayılan değer false olur.

Devralma

azureml.core._portal.HasPipelinePortal

PublishedPipeline

Oluşturucu

PublishedPipeline(name, graph_id, description, version, published_pipeline_id, status, endpoint, total_run_steps, workspace, continue_on_step_failure=None, _pipeline_provider=None, **kwargs)

Parametreler

name

str

Gerekli

Yayımlanan işlem hattının adı.

graph_id

str

Gerekli

Yayımlanan bu işlem hattının grafiğinin kimliği.

description

str

Gerekli

Yayımlanan işlem hattının açıklaması.

version

str

Gerekli

Yayımlanan işlem hattı sürümü.

published_pipeline_id

str

Gerekli

Yayımlanan işlem hattının kimliği.

status

str

Gerekli

Yayımlanan işlem hattının durumu ('Etkin' veya 'Devre Dışı').

endpoint

str

Gerekli

Göndermek için REST uç nokta URL'si bu işlem hattı için çalışır.

total_run_steps

int

Gerekli

Bu işlem hattındaki adım sayısı.

workspace

Workspace

Gerekli

Yayımlanan işlem hattının çalışma alanı.

continue_on_step_failure

bool

Gerekli

Bir adım başarısız olursa PipelineRun'daki diğer adımların yürütülmesine devam edilip edilmeyeceği. Varsayılan değer false.

_pipeline_provider

<xref:azureml.pipeline.core._workflow_provider._PublishedPipelineProvider>

Gerekli

Yayımlanan işlem hattı sağlayıcısı.

kwargs

dict

Gerekli

Gelecekteki geliştirme için ayrılmış özel anahtar sözcük bağımsız değişkenleri

name

str

Gerekli

Yayımlanan işlem hattının adı.

graph_id

str

Gerekli

Yayımlanan bu işlem hattının grafiğinin kimliği.

description

str

Gerekli

Yayımlanan işlem hattının açıklaması.

version

str

Gerekli

Yayımlanan işlem hattı sürümü.

published_pipeline_id

str

Gerekli

Yayımlanan işlem hattının kimliği.

status

str

Gerekli

Yayımlanan işlem hattının durumu ('Etkin' veya 'Devre Dışı').

_pipeline_provider

<xref:azureml.pipeline.core._workflow_provider._PublishedPipelineProvider>

Gerekli

Yayımlanan işlem hattı sağlayıcısı.

kwargs

dict

Gerekli

Gelecekteki geliştirme için ayrılmış özel anahtar sözcük bağımsız değişkenleri

Açıklamalar

PublishedPipeline, bir Pipeline veya PipelineRuniçinden oluşturulabilir.

İşlem hattından yayımlama örneği aşağıdaki gibidir:

   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'dan yayımlamak için şu komutu kullanın:

   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)

Not: continue_on_step_failure parametresi, bir adım başarısız olursa İşlem Hattındaki adımların yürütülmesinin devam edip etmeyeceğini belirtir. Varsayılan değer False'tur, yani bir adım başarısız olduğunda İşlem Hattı yürütmesi durdurularak çalışan adımları iptal eder.

kullanarak submitbir PublishedPipeline gönderin. Gönder çağrıldığında, iş akışındaki her adım için nesneler oluşturan StepRun bir PipelineRun oluşturulur.

PublishedPipeline gönderme örneği aşağıdaki gibidir:

   from azureml.pipeline.core import PublishedPipeline

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

PublishedPipeline gönderilirken belirtilebilen bir dizi isteğe bağlı ayar vardır. Bu modüller şunlardır:

• continue_on_step_failure: Bir adım başarısız olursa pipelinerun içindeki diğer adımların yürütülmesine devam edilip edilmeyeceği isteğe bağlıdır. Yalnızca başarısız adımın çıkışına bağımlılığı olmayan adımlar yürütülmeye devam eder. Sağlanırsa, bu parametre ayarı İşlem Hattı'nda ayarı geçersiz kılar.

• pipeline_parameters: İşlem hattı yürütme parametreleri, {name: value} sözlüğü. Diğer ayrıntılar için bkz PipelineParameter .

• parent_run_id: RunHistory'ye yansıtılan bu işlem hattı çalıştırmasının üst çalıştırmasını ayarlamak için bir çalıştırma kimliği sağlayabilirsiniz. Üst çalıştırma, gönderilen işlem hattıyla aynı denemeye ait olmalıdır.

Bu ayarları kullanarak PublishedPipeline gönderme örneği aşağıdaki gibidir:

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

Yayımlanan tüm işlem hatlarının rest uç noktası vardır. İşlem hattı uç noktası ile Python olmayan istemciler gibi dış sistemlerden işlem hattının çalıştırılmasını tetikleyebilirsiniz. REST uç noktalarını çağırırken kimlik doğrulaması yapma hakkında bilgi için bkz https://aka.ms/pl-restep-auth. .

Uç noktanın kullanılması, örneğin toplu puanlama ve yeniden eğitme senaryolarında "yönetilen yinelenebilirliği" etkinleştirir. Daha fazla bilgi için bkz. https://aka.ms/pl-first-pipeline.

Yöntemler

disable	Yayımlanan işlem hattını 'Devre dışı' olarak ayarlayın ve çalıştırılamıyor.
enable	Yayımlanan işlem hattını 'Etkin' olarak ayarlayın ve çalıştırılabilir.
get	Yayımlanan işlem hattını alın.
get_all	Geçerli çalışma alanında yayımlanan tüm işlem hatlarını alın. KULLANIMDAN KALDıRILDI: Bu yöntem PublishedPipeline list yöntemine göre kullanım dışı bırakılıyor.
get_graph	PublishedPipeline grafiğini alın.
get_step_names	PublishedPipeline içindeki adım adlarının listesini alın.
list	Geçerli çalışma alanında yayımlanan tüm işlem hatlarını alın.
save	İşlem Hattı YAML'sini bir dosyaya kaydedin. Şu anda YAML dışarı aktarma için yalnızca ModuleSteps'i içeren işlem hatları desteklenmektedir.
submit	Yayımlanan işlem hattını gönderin. Bu, kullanmakla submiteşdeğerdir. Gönderilen PipelineRunöğesini döndürür. Çalıştırmanın ayrıntılarını izlemek ve görüntülemek için bu nesneyi kullanın.

disable

Yayımlanan işlem hattını 'Devre dışı' olarak ayarlayın ve çalıştırılamıyor.

disable()

enable

Yayımlanan işlem hattını 'Etkin' olarak ayarlayın ve çalıştırılabilir.

enable()

get

Yayımlanan işlem hattını alın.

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

Parametreler

workspace

Workspace

Gerekli

Yayımlanan işlem hattının oluşturulduğu çalışma alanı.

id

str

Gerekli

Yayımlanan işlem hattının kimliği.

_workflow_provider

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

varsayılan değer: None

İş akışı sağlayıcısı.

_service_endpoint

str

varsayılan değer: None

Hizmet uç noktası.

Döndürülenler

PublishedPipeline nesnesi.

Dönüş türü

PublishedPipeline

get_all

Geçerli çalışma alanında yayımlanan tüm işlem hatlarını alın.

KULLANIMDAN KALDıRILDI: Bu yöntem PublishedPipeline list yöntemine göre kullanım dışı bırakılıyor.

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

Parametreler

workspace

Workspace

Gerekli

Yayımlanan işlem hattının oluşturulduğu çalışma alanı.

active_only

bool

varsayılan değer: True

Yalnızca şu anda etkin olan yayımlanmış işlem hatlarının döndürülip döndürülmeyeceği.

_service_endpoint

str

varsayılan değer: None

Hizmet uç noktası.

Döndürülenler

PublishedPipeline nesnelerinin listesi.

Dönüş türü

list[PublishedPipeline]

get_graph

PublishedPipeline grafiğini alın.

get_graph(_workflow_provider=None)

Parametreler

_workflow_provider

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

varsayılan değer: None

İş akışı sağlayıcısı.

Döndürülenler

Grafik.

Dönüş türü

Graph

get_step_names

PublishedPipeline içindeki adım adlarının listesini alın.

get_step_names(_workflow_provider=None)

Parametreler

_workflow_provider

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

varsayılan değer: None

İş akışı sağlayıcısı.

Döndürülenler

PublishedPipeline içindeki adım adlarının listesi.

Dönüş türü

List[str]

list

Geçerli çalışma alanında yayımlanan tüm işlem hatlarını alın.

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

Parametreler

workspace

Workspace

Gerekli

Yayımlanan işlem hattının oluşturulduğu çalışma alanı.

active_only

bool

varsayılan değer: True

Yalnızca şu anda etkin olan yayımlanmış işlem hatlarının döndürülip döndürülmeyeceği.

_service_endpoint

str

varsayılan değer: None

Hizmet uç noktası.

Döndürülenler

PublishedPipeline nesnelerinin listesi.

Dönüş türü

list[PublishedPipeline]

save

İşlem Hattı YAML'sini bir dosyaya kaydedin.

Şu anda YAML dışarı aktarma için yalnızca ModuleSteps'i içeren işlem hatları desteklenmektedir.

save(path=None, _workflow_provider=None)

Parametreler

path

str

varsayılan değer: None

YAML'nin kaydedilecek yolu. Yol bir dizinse, İşlem Hattı YAML dosyası path/pipeline_name.yml adresine kaydedilir. Yol Yok ise geçerli dizin kullanılır.

_workflow_provider

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

varsayılan değer: None

İş akışı sağlayıcısı.

Dönüş türü

None

submit

Yayımlanan işlem hattını gönderin. Bu, kullanmakla submiteşdeğerdir.

Gönderilen PipelineRunöğesini döndürür. Çalıştırmanın ayrıntılarını izlemek ve görüntülemek için bu nesneyi kullanın.

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

Parametreler

workspace

Workspace

Gerekli

Yayımlanan işlem hattının gönder iletişim alanının açık olduğu çalışma alanı.

experiment_name

str

Gerekli

Gönderilecek denemenin adı.

pipeline_parameters

dict

varsayılan değer: None

{param name, param value} yeni değerleri atamak için parametre sözlüğü. Diğer ayrıntılar için bkz PipelineParameter .

_workflow_provider

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

varsayılan değer: None

İş akışı sağlayıcısı.

_service_endpoint

str

varsayılan değer: None

Hizmet uç noktası.

parent_run_id

str

varsayılan değer: None

RunHistory'ye yansıtılan bu işlem hattı çalıştırmasının üst çalıştırması için ayarlayabileceğiniz isteğe bağlı çalıştırma kimliği. Üst çalıştırma, bu işlem hattının gönderildiği denemenin aynısına ait olmalıdır.

continue_on_step_failure

bool

varsayılan değer: None

Bir adım başarısız olursa PipelineRun'daki diğer adımların yürütülmesine devam edilip edilmeyeceği isteğe bağlıdır. Sağlanırsa, İşlem Hattı'nda ayarı geçersiz kılar.

Döndürülenler

Gönderilen işlem hattı çalıştırması.

Dönüş türü

PipelineRun

Öznitelikler

continue_on_step_failure

Ayarın continue_on_step_failure değerini alın.

Döndürülenler

Ayarın continue_on_step_failure değeri.

Dönüş türü

bool

description

Yayımlanan işlem hattının açıklamasını alın.

Döndürülenler

Yayımlanan işlem hattının açıklaması.

Dönüş türü

str

endpoint

Yayımlanan işlem hattını çalıştırmak için REST uç nokta URL'sini alın.

Döndürülenler

Yayımlanan işlem hattını çalıştırmak için REST uç nokta URL'si.

Dönüş türü

str

graph_id

Yayımlanan bu işlem hattının grafiğinin kimliğini alın.

Döndürülenler

Grafiğin kimliği.

Dönüş türü

str

id

Yayımlanan işlem hattı kimliğini alın.

Döndürülenler

Yayımlanan işlem hattının kimliği.

Dönüş türü

str

name

Yayımlanan işlem hattının adını alın.

Döndürülenler

Yayımlanan işlem hattı adı.

Dönüş türü

str

status

Yayımlanan işlem hattının durumunu alın.

Döndürülenler

Yayımlanan işlem hattının durumu.

Dönüş türü

str

total_run_steps

İşlem hattındaki adım sayısını alın.

Döndürülenler

İşlem hattındaki adım sayısı.

Dönüş türü

int

version

Yayımlanan işlem hattının sürümünü alın.

Döndürülenler

Yayımlanan işlem hattının sürümü.

Dönüş türü

str