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.HasPipelinePortalPublishedPipeline
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
|
Yayımlanan işlem hattının adı. |
graph_id
Gerekli
|
Yayımlanan bu işlem hattının grafiğinin kimliği. |
description
Gerekli
|
Yayımlanan işlem hattının açıklaması. |
version
Gerekli
|
Yayımlanan işlem hattı sürümü. |
published_pipeline_id
Gerekli
|
Yayımlanan işlem hattının kimliği. |
status
Gerekli
|
Yayımlanan işlem hattının durumu ('Etkin' veya 'Devre Dışı'). |
endpoint
Gerekli
|
Göndermek için REST uç nokta URL'si bu işlem hattı için çalışır. |
total_run_steps
Gerekli
|
Bu işlem hattındaki adım sayısı. |
workspace
Gerekli
|
Yayımlanan işlem hattının çalışma alanı. |
continue_on_step_failure
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
Gerekli
|
<xref:azureml.pipeline.core._workflow_provider._PublishedPipelineProvider>
Yayımlanan işlem hattı sağlayıcısı. |
kwargs
Gerekli
|
Gelecekteki geliştirme için ayrılmış özel anahtar sözcük bağımsız değişkenleri |
name
Gerekli
|
Yayımlanan işlem hattının adı. |
graph_id
Gerekli
|
Yayımlanan bu işlem hattının grafiğinin kimliği. |
description
Gerekli
|
Yayımlanan işlem hattının açıklaması. |
version
Gerekli
|
Yayımlanan işlem hattı sürümü. |
published_pipeline_id
Gerekli
|
Yayımlanan işlem hattının kimliği. |
status
Gerekli
|
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
|
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
|
Yayımlanan işlem hattının oluşturulduğu çalışma alanı. |
id
Gerekli
|
Yayımlanan işlem hattının kimliği. |
_workflow_provider
|
<xref:azureml.pipeline.core._aeva_provider._AevaWorkflowProvider>
İş akışı sağlayıcısı. Default value: None
|
_service_endpoint
|
Hizmet uç noktası. Default value: None
|
Döndürülenler
Tür | Description |
---|---|
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
|
Yayımlanan işlem hattının oluşturulduğu çalışma alanı. |
active_only
|
Yalnızca şu anda etkin olan yayımlanmış işlem hatlarının döndürülip döndürülmeyeceği. Default value: True
|
_service_endpoint
|
Hizmet uç noktası. Default value: None
|
Döndürülenler
Tür | Description |
---|---|
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ı. Default value: None
|
Döndürülenler
Tür | Description |
---|---|
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ı. Default value: None
|
Döndürülenler
Tür | Description |
---|---|
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
|
Yayımlanan işlem hattının oluşturulduğu çalışma alanı. |
active_only
|
Yalnızca şu anda etkin olan yayımlanmış işlem hatlarının döndürülip döndürülmeyeceği. Default value: True
|
_service_endpoint
|
Hizmet uç noktası. Default value: None
|
Döndürülenler
Tür | Description |
---|---|
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
|
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. Default value: None
|
_workflow_provider
|
<xref:azureml.pipeline.core._aeva_provider._AevaWorkflowProvider>
İş akışı sağlayıcısı. Default value: None
|
Döndürülenler
Tür | Description |
---|---|
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
|
Yayımlanan işlem hattının gönder iletişim alanının açık olduğu çalışma alanı. |
experiment_name
Gerekli
|
Gönderilecek denemenin adı. |
pipeline_parameters
|
{param name, param value} yeni değerleri atamak için parametre sözlüğü. Diğer ayrıntılar için bkz PipelineParameter . Default value: None
|
_workflow_provider
|
<xref:azureml.pipeline.core._aeva_provider._AevaWorkflowProvider>
İş akışı sağlayıcısı. Default value: None
|
_service_endpoint
|
Hizmet uç noktası. Default value: None
|
parent_run_id
|
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. Default value: None
|
continue_on_step_failure
|
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. Default value: None
|
Döndürülenler
Tür | Description |
---|---|
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 |
---|---|
Ayarın |
description
Yayımlanan işlem hattının açıklamasını alın.
Döndürülenler
Tür | Description |
---|---|
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 |
---|---|
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 |
---|---|
Grafiğin kimliği. |
id
Yayımlanan işlem hattı kimliğini alın.
Döndürülenler
Tür | Description |
---|---|
Yayımlanan işlem hattının kimliği. |
name
status
Yayımlanan işlem hattının durumunu alın.
Döndürülenler
Tür | Description |
---|---|
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 |
---|---|
İş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 |
---|---|
Yayımlanan işlem hattının sürümü. |