PublishedPipeline Sınıf

Başvuru

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	Description
name Gerekli	str Yayımlanan işlem hattının adı.
graph_id Gerekli	str Yayımlanan bu işlem hattının grafiğinin kimliği.
description Gerekli	str Yayımlanan işlem hattının açıklaması.
version Gerekli	str Yayımlanan işlem hattı sürümü.
published_pipeline_id Gerekli	str Yayımlanan işlem hattının kimliği.
status Gerekli	str Yayımlanan işlem hattının durumu ('Etkin' veya 'Devre Dışı').
endpoint Gerekli	str Göndermek için REST uç nokta URL'si bu işlem hattı için çalışır.
total_run_steps Gerekli	int Bu işlem hattındaki adım sayısı.
workspace Gerekli	Workspace Yayımlanan işlem hattının çalışma alanı.
continue_on_step_failure Gerekli	bool 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 Gerekli	<xref:azureml.pipeline.core._workflow_provider._PublishedPipelineProvider> Yayımlanan işlem hattı sağlayıcısı.
kwargs Gerekli	dict Gelecekteki geliştirme için ayrılmış özel anahtar sözcük bağımsız değişkenleri
name Gerekli	str Yayımlanan işlem hattının adı.
graph_id Gerekli	str Yayımlanan bu işlem hattının grafiğinin kimliği.
description Gerekli	str Yayımlanan işlem hattının açıklaması.
version Gerekli	str Yayımlanan işlem hattı sürümü.
published_pipeline_id Gerekli	str Yayımlanan işlem hattının kimliği.
status Gerekli	str Yayımlanan işlem hattının durumu ('Etkin' veya 'Devre Dışı').
_pipeline_provider Gerekli	<xref:azureml.pipeline.core._workflow_provider._PublishedPipelineProvider> Yayımlanan işlem hattı sağlayıcısı.
kwargs Gerekli	dict 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

Name	Description
workspace Gerekli	Workspace Yayımlanan işlem hattının oluşturulduğu çalışma alanı.
id Gerekli	str Yayımlanan işlem hattının kimliği.
_workflow_provider	<xref:azureml.pipeline.core._aeva_provider._AevaWorkflowProvider> İş akışı sağlayıcısı. varsayılan değer: None
_service_endpoint	str Hizmet uç noktası. varsayılan değer: None

Döndürülenler

Tür	Description
PublishedPipeline	PublishedPipeline nesnesi.

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

Name	Description
workspace Gerekli	Workspace Yayımlanan işlem hattının oluşturulduğu çalışma alanı.
active_only	bool Yalnızca şu anda etkin olan yayımlanmış işlem hatlarının döndürülip döndürülmeyeceği. varsayılan değer: True
_service_endpoint	str Hizmet uç noktası. varsayılan değer: None

Döndürülenler

Tür	Description
list[PublishedPipeline]	PublishedPipeline nesnelerinin listesi.

get_graph

PublishedPipeline grafiğini alın.

get_graph(_workflow_provider=None)

Parametreler

Name	Description
_workflow_provider	<xref:azureml.pipeline.core._aeva_provider._AevaWorkflowProvider> İş akışı sağlayıcısı. varsayılan değer: None

Döndürülenler

Tür	Description
Graph	Grafik.

get_step_names

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

get_step_names(_workflow_provider=None)

Parametreler

Name	Description
_workflow_provider	<xref:azureml.pipeline.core._aeva_provider._AevaWorkflowProvider> İş akışı sağlayıcısı. varsayılan değer: None

Döndürülenler

Tür	Description
List[str]	PublishedPipeline içindeki adım adlarının listesi.

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

Name	Description
workspace Gerekli	Workspace Yayımlanan işlem hattının oluşturulduğu çalışma alanı.
active_only	bool Yalnızca şu anda etkin olan yayımlanmış işlem hatlarının döndürülip döndürülmeyeceği. varsayılan değer: True
_service_endpoint	str Hizmet uç noktası. varsayılan değer: None

Döndürülenler

Tür	Description
list[PublishedPipeline]	PublishedPipeline nesnelerinin listesi.

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

Name	Description
path	str 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. varsayılan değer: None
_workflow_provider	<xref:azureml.pipeline.core._aeva_provider._AevaWorkflowProvider> İş akışı sağlayıcısı. varsayılan değer: None

Döndürülenler

Tür	Description
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

Name	Description
workspace Gerekli	Workspace Yayımlanan işlem hattının gönder iletişim alanının açık olduğu çalışma alanı.
experiment_name Gerekli	str Gönderilecek denemenin adı.
pipeline_parameters	dict {param name, param value} yeni değerleri atamak için parametre sözlüğü. Diğer ayrıntılar için bkz PipelineParameter . varsayılan değer: None
_workflow_provider	<xref:azureml.pipeline.core._aeva_provider._AevaWorkflowProvider> İş akışı sağlayıcısı. varsayılan değer: None
_service_endpoint	str Hizmet uç noktası. varsayılan değer: None
parent_run_id	str 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. varsayılan değer: None
continue_on_step_failure	bool 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. varsayılan değer: None

Döndürülenler

Tür	Description
PipelineRun	Gönderilen işlem hattı çalıştırması.

Öznitelikler

continue_on_step_failure

Ayarın continue_on_step_failure değerini alın.

Döndürülenler

Tür	Description
bool	Ayarın `continue_on_step_failure` değeri.

description

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

Döndürülenler

Tür	Description
str	Yayımlanan işlem hattının açıklaması.

endpoint

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

Döndürülenler

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

graph_id

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

Döndürülenler

Tür	Description
str	Grafiğin kimliği.

id

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

Döndürülenler

Tür	Description
str	Yayımlanan işlem hattının kimliği.

name

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

Döndürülenler

Tür	Description
str	Yayımlanan işlem hattı adı.

status

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

Döndürülenler

Tür	Description
str	Yayımlanan işlem hattının durumu.

total_run_steps

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

Döndürülenler

Tür	Description
int	İşlem hattındaki adım sayısı.

version

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

Döndürülenler

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

Share via

PublishedPipeline Sınıf

Oluşturucu

Parametreler

Açıklamalar

Yöntemler

disable

enable

get

Parametreler

Döndürülenler

get_all

Parametreler

Döndürülenler

get_graph

Parametreler

Döndürülenler

get_step_names

Parametreler

Döndürülenler

list

Parametreler

Döndürülenler

save

Parametreler

Döndürülenler

submit

Parametreler

Döndürülenler

Öznitelikler

continue_on_step_failure

Döndürülenler

description

Döndürülenler

endpoint

Döndürülenler

graph_id

Döndürülenler

id

Döndürülenler

name

Döndürülenler

status

Döndürülenler

total_run_steps

Döndürülenler

version

Döndürülenler

Geri Bildirim

Geri Bildirim

Ek kaynaklar