PublishedPipeline 類別

  • 參考

表示要提交且沒有建構它的 Python 程式碼的管線。

此外，PublishedPipeline 可用來重新提交 Pipeline 具有不同 PipelineParameter 值和輸入的 。

初始化 PublishedPipeline。

:p aram 端點 要提交此管線執行的 REST 端點 URL。 ：type endpoint： str :p aram total_run_steps：此管線中的步驟數目：type total_run_steps：int :p aram 工作區：已發佈管線的工作區。 ：type workspace： azureml.core.Workspace :p aram continue_on_step_failure：是否繼續執行 PipelineRun 中的其他步驟

如果步驟失敗，則預設值為 false。

繼承
azureml.core._portal.HasPipelinePortal
PublishedPipeline

建構函式

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

參數

name
str
必要

已發佈管線的名稱。

graph_id
str
必要

這個已發佈管線的圖形識別碼。

description
str
必要

已發佈管線的描述。

version
str
必要

已發佈的管線版本。

published_pipeline_id
str
必要

已發佈管線的識別碼。

status
str
必要

已發佈管線的狀態 ('Active' 或 'Disabled') 。

endpoint
str
必要

要提交此管線執行的 REST 端點 URL。

total_run_steps
int
必要

此管線中的步驟數目。

workspace
Workspace
必要

已發佈管線的工作區。

continue_on_step_failure
bool
必要

如果步驟失敗，是否要繼續執行 PipelineRun 中的其他步驟。 預設值為 false。

_pipeline_provider
<xref:azureml.pipeline.core._workflow_provider._PublishedPipelineProvider>
必要

已發佈的管線提供者。

kwargs
dict
必要

自訂關鍵字引數，保留供未來開發使用

name
str
必要

已發佈管線的名稱。

graph_id
str
必要

這個已發佈管線的圖形識別碼。

description
str
必要

已發佈管線的描述。

version
str
必要

已發佈的管線版本。

published_pipeline_id
str
必要

已發佈管線的識別碼。

status
str
必要

已發佈管線的狀態 ('Active' 或 'Disabled') 。

_pipeline_provider
<xref:azureml.pipeline.core._workflow_provider._PublishedPipelineProvider>
必要

已發佈的管線提供者。

kwargs
dict
必要

自訂關鍵字引數，保留供未來開發使用

備註

您可以從 或 PipelineRun 建立 Pipeline PublishedPipeline。

從管線發佈的範例如下所示：


   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 發佈，請使用：


   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)

注意：continue_on_step_failure參數會指定管線中的步驟執行是否會在單一步驟失敗時繼續執行。 預設值為 False，表示當某個步驟失敗時，管線執行將會停止，並取消任何執行中的步驟。

使用 submit 提交 PublishedPipeline。 呼叫 submit 時，會建立 ， PipelineRun 進而為工作流程中的每個步驟建立 StepRun 物件。

提交 PublishedPipeline 的範例如下：


   from azureml.pipeline.core import PublishedPipeline

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

提交 PublishedPipeline 時可以指定許多選擇性設定。 其中包括：

  • continue_on_step_failure：如果步驟失敗，是否要繼續執行 PipelineRun 中的其他步驟，選擇性。 只有沒有相依于失敗步驟輸出的步驟才會繼續執行。 如果提供，此參數設定會覆寫管線上的設定。

  • pipeline_parameters：管線執行的參數，{name： value} 的字典。 如需更多詳細資料，請參閱 PipelineParameter \(英文\)。

  • parent_run_id：您可以提供執行識別碼來設定此管線執行的父回合，這會反映在 RunHistory 中。 父回合必須屬於與提交管線相同的實驗。

使用下列設定提交 PublishedPipeline 的範例如下：


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

所有已發佈的管線都有 REST 端點。 透過管線端點，您可以從外部系統觸發管線的執行，例如非 Python 用戶端。 如需如何呼叫 REST 端點時進行驗證的資訊，請參閱 https://aka.ms/pl-restep-auth 。

例如，使用端點可在批次評分和重新定型案例中啟用「受控可重複性」。 如需詳細資訊，請參閱 https://aka.ms/pl-first-pipeline 。

方法

disable

將已發佈的管線設定為 [已停用]，且無法執行。
enable

將已發佈的管線設定為 [作用中]，並可供執行。
get

取得已發佈的管線。
get_all

取得目前工作區中所有已發佈的管線。

已淘汰：這個方法已被取代，而不是 PublishedPipeline list 方法。
get_graph

取得 PublishedPipeline 的圖表。
get_step_names

取得 PublishedPipeline 中步驟的名稱清單。
list

取得目前工作區中所有已發佈的管線。
save

將管線 YAML 儲存至檔案。

目前只有包含 ModuleSteps 的管線才支援 YAML 匯出。
submit

提交已發佈的管線。 這相當於使用 submit 。

傳回提交的 PipelineRun 。 使用此物件來監視及檢視執行的詳細資料。

disable

將已發佈的管線設定為 [已停用]，且無法執行。

disable()

enable

將已發佈的管線設定為 [作用中]，並可供執行。

enable()

get

取得已發佈的管線。

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

參數

workspace
Workspace
必要

已發佈管線建立所在的工作區。

id
str
必要

已發佈管線的識別碼。

_workflow_provider
<xref:azureml.pipeline.core._aeva_provider._AevaWorkflowProvider>
預設值: None

工作流程提供者。

_service_endpoint
str
預設值: None

服務端點。

傳回

PublishedPipeline 物件。

傳回類型

PublishedPipeline

get_all

取得目前工作區中所有已發佈的管線。

已淘汰：這個方法已被取代，而不是 PublishedPipeline list 方法。

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

參數

workspace
Workspace
必要

已發佈管線建立所在的工作區。

active_only
bool
預設值: True

是否只傳回目前作用中的已發佈管線。

_service_endpoint
str
預設值: None

服務端點。

傳回

PublishedPipeline 物件的清單。

傳回類型

list[PublishedPipeline]

get_graph

取得 PublishedPipeline 的圖表。

get_graph(_workflow_provider=None)

參數

_workflow_provider
<xref:azureml.pipeline.core._aeva_provider._AevaWorkflowProvider>
預設值: None

工作流程提供者。

傳回

圖形。

傳回類型

Graph

get_step_names

取得 PublishedPipeline 中步驟的名稱清單。

get_step_names(_workflow_provider=None)

參數

_workflow_provider
<xref:azureml.pipeline.core._aeva_provider._AevaWorkflowProvider>
預設值: None

工作流程提供者。

傳回

PublishedPipeline 中的步驟名稱清單。

傳回類型

List[str]

list

取得目前工作區中所有已發佈的管線。

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

參數

workspace
Workspace
必要

已發佈管線建立所在的工作區。

active_only
bool
預設值: True

是否只傳回目前作用中的已發佈管線。

_service_endpoint
str
預設值: None

服務端點。

傳回

PublishedPipeline 物件的清單。

傳回類型

list[PublishedPipeline]

save

將管線 YAML 儲存至檔案。

目前只有包含 ModuleSteps 的管線才支援 YAML 匯出。

save(path=None, _workflow_provider=None)

參數

path
str
預設值: None

要儲存 YAML 的路徑。 如果路徑是目錄，管線 YAML 檔案會儲存在 path/pipeline_name.yml。 如果 path 為 None，則會使用目前的目錄。

_workflow_provider
<xref:azureml.pipeline.core._aeva_provider._AevaWorkflowProvider>
預設值: None

工作流程提供者。

傳回類型

None

submit

提交已發佈的管線。 這相當於使用 submit 。

傳回提交的 PipelineRun 。 使用此物件來監視及檢視執行的詳細資料。

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

參數

workspace
Workspace
必要

要提交已發佈管線的工作區。

experiment_name
str
必要

要提交至的實驗名稱。

pipeline_parameters
dict
預設值: None

要指派新值 {param name， param value} 的參數字典。 如需更多詳細資料，請參閱 PipelineParameter \(英文\)。

_workflow_provider
<xref:azureml.pipeline.core._aeva_provider._AevaWorkflowProvider>
預設值: None

工作流程提供者。

_service_endpoint
str
預設值: None

服務端點。

parent_run_id
str
預設值: None

要為此管線執行的父回合設定的選擇性執行識別碼，這會反映在 RunHistory 中。 父執行必須屬於與提交此管線相同的實驗。

continue_on_step_failure
bool
預設值: None

如果步驟失敗，是否要繼續執行 PipelineRun 中的其他步驟，選擇性。 如果提供，將會覆寫管線上的設定。

傳回

提交的管線執行。

傳回類型

PipelineRun

屬性

continue_on_step_failure

取得設定的值 continue_on_step_failure 。

傳回

設定的值 continue_on_step_failure 。

傳回類型

bool

description

取得已發佈管線的描述。

傳回

已發佈管線的描述。

傳回類型

str

endpoint

取得用於執行已發佈管線的 REST 端點 URL。

傳回

用於執行已發佈管線的 REST 端點 URL。

傳回類型

str

graph_id

取得此已發佈管線的圖形識別碼。

傳回

圖形的識別碼。

傳回類型

str

id

取得已發佈的管線識別碼。

傳回

已發佈管線的識別碼。

傳回類型

str

name

取得已發佈管線的名稱。

傳回

已發佈的管線名稱。

傳回類型

str

status

取得已發佈管線的狀態。

傳回

已發佈管線的狀態。

傳回類型

str

total_run_steps

取得管線中的步驟數目。

傳回

管線中的步驟數目。

傳回類型

int

version

取得已發佈管線的版本。

傳回

已發佈管線的版本。

傳回類型

str