PipelineEndpoint クラス
一意のエンドポイント URL からトリガーできる Pipeline ワークフローを表します。
PipelineEndpoint を使用すると、同じエンドポイントを維持しながら PublishedPipeline の新しいバージョンを作成できます。 PipelineEndpoint には、ワークスペース内で一意の名前が付けられます。
PipelineEndpoint オブジェクトの endpoint 属性を使用すると、外部アプリケーションから REST 呼び出しを使用して新しいパイプライン実行をトリガーできます。 REST エンドポイントを呼び出すときの認証方法については、https://aka.ms/pl-restep-auth を参照してください。
機械学習パイプラインの作成と実行の詳細については、https://aka.ms/pl-first-pipeline を参照してください。
PipelineEndpoint を初期化します。
- 継承
-
builtins.objectPipelineEndpoint
コンストラクター
PipelineEndpoint(workspace, id, name, description, status, default_version, endpoint, pipeline_version_list, _pipeline_endpoint_provider=None, _published_pipeline_provider=None, _swaggerurl=None)
パラメーター
名前 | 説明 |
---|---|
workspace
必須
|
PipelineEndpoint が定義されているワークスペース。 |
id
必須
|
PipelineEndpoint の ID。 |
name
必須
|
PipelineEndpoint の名前。 |
description
必須
|
PipelineEndpoint の説明。 |
status
必須
|
PipelineEndpoint の新しい状態: 'Active' または 'Disabled'。 |
default_version
必須
|
PipelineEndpoint のパイプラインの既定のバージョン (自動インクリメント) は、"0" で始まります。 |
endpoint
必須
|
パイプラインの実行を送信するために使用できる、PipelineEndpoint の REST エンドポイント URL。 |
pipeline_version_list
必須
|
PipelineIdVersion オブジェクトのリスト。 |
_pipeline_endpoint_provider
必須
|
<xref:azureml.pipeline.core._aeva_provider._AevaPublishedPipelineProvider>
PipelineEndpoint プロバイダー。 |
_pipeline_endpoint_provider
必須
|
PublishedPipeline プロバイダー。 |
workspace
必須
|
PipelineEndpoint が属するワークスペース オブジェクト。 |
id
必須
|
PipelineEndpoint の ID。 |
name
必須
|
PipelineEndpoint の名前。 |
description
必須
|
PipelineEndpoint の説明。 |
status
必須
|
PipelineEndpoint の新しい状態: 'Active' または 'Disabled'。 |
default_version
必須
|
PipelineEndpoint のパイプラインの既定のバージョン (自動インクリメント) は、"0" で始まります |
endpoint
必須
|
パイプラインの実行を送信する PipelineEndpoint の REST エンドポイント URL。 |
pipeline_version_list
必須
|
|
_pipeline_endpoint_provider
必須
|
<xref:azureml.pipeline.core._aeva_provider._AevaPublishedPipelineProvider>
PipelineEndpoint プロバイダー。 |
_pipeline_endpoint_provider
必須
|
PublishedPipeline プロバイダー。 |
swaggerendpoint
必須
|
パイプラインの実行を送信する PipelineEndpoint の Swagger REST エンドポイント URL。 |
注釈
PipelineEndpoint は、Pipeline または PublishedPipeline のいずれからでも作成できます。
Pipeline または PublishedPipeline から公開する例を次に示します。
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")
submit を使用して PipelineEndpoint を送信します。 submit が呼び出されると、PipelineRun が作成され、ワークフローの各ステップに対して順番に StepRun オブジェクトが作成されます。
PipelineEndpoint を送信する方法の例を次に示します。
from azureml.pipeline.core import PipelineEndpoint
pipeline_endpoint = PipelineEndpoint.get(workspace=ws, name="PipelineEndpointName")
pipeline_run = experiment.submit(pipeline_endpoint)
PipelineEndpoint を送信するときに指定できる省略可能な設定が多数あります。 これには以下が含まれます。
pipeline_parameters: パイプライン実行のパラメーター。{name: value} の辞書。 詳細については、 PipelineParameter をご覧ください。
parent_run_id: RunHistory に反映される、このパイプライン実行の親実行を設定する実行 ID を指定できます。 親の実行は、このパイプラインが送信されるのと同じ実験に属している必要があります。
pipeline_version: 実行するパイプライン バージョン。
これらの設定を使用して PipelineEndpoint を送信する例を次に示します。
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")
PipelineEndpoint の新しいバージョンを追加するには、以下を使用します。
from azureml.pipeline.core import PipelineEndpoint
pipeline_endpoint = PipelineEndpoint.get(workspace=ws, name="PipelineEndpointName")
pipeline_endpoint.add(published_pipeline)
PipelineEndpoint の作成と使用の詳細については、次のノートブックを参照してください: https://aka.ms/pl-ver-endpoint。
メソッド
add |
指定したパイプラインを PipelineEndpoint に追加します。 |
add_default |
指定したパイプラインを PipelineEndpoint に追加し、既定のバージョンを、追加したパイプライン バージョンに設定します。 |
archive |
PipelineEndpoint をアーカイブします。 |
disable |
PipelineEndpoint を 'Disabled' に設定し、実行できないようにします。 |
enable |
PipelineEndpoint を 'Active' に設定し、実行できるようにします。 |
get |
名前または ID で PipelineEndpoint を取得します。どちらも指定されていない場合は例外をスローします。 |
get_all |
現在のワークスペース内のすべてのアクティブな PipelineEndpoint を取得します。 すべてのアクティブな PipelineEndpoint を取得します。 メモ: このメソッドは非推奨となる予定であり、PipelineEndpoint.list() が優先になります。 |
get_all_pipelines |
PipelineEndpoint のパイプラインの一覧を取得します。 メモ: このメソッドは非推奨となる予定であり、list_pipelines() が優先になります |
get_all_versions |
PipelineEndpoint のパイプラインおよび対応するバージョンの一覧を取得します。 メモ: このメソッドは非推奨となる予定であり、list_versions() が優先になります |
get_default_version |
PipelineEndpoint の既定のバージョンを取得します。 |
get_pipeline |
指定したバージョンまたは既定のパイプラインを取得します。バージョンが見つからない場合は、例外をスローします。 |
list |
現在のワークスペース内のアクティブな PipelineEndpoint を一覧表示します。 |
list_pipelines |
PipelineEndpoint に関連付けられているパイプラインの一覧を取得します。 |
list_versions |
PipelineEndpoint のパイプラインおよび対応するバージョンの一覧を取得します。 |
publish |
指定した名前とパイプラインまたは公開されたパイプラインを使用して、PipelineEndpoint を作成します。 パイプライン エンドポイントは、外部アプリケーションから使用できる REST API です。 REST エンドポイントを呼び出すときの認証方法については、https://aka.ms/pl-restep-auth を参照してください。 パイプライン エンドポイントの操作の詳細については、https://aka.ms/pl-first-pipeline を参照してください。 指定した名前の PipelineEndpoint が既に存在する場合は、例外をスローします。 |
reactivate |
アーカイブされた PipelineEndpoint を再アクティブ化します。 |
set_default |
PipelineEndpoint の既定のバージョンを設定します。指定したパイプラインが見つからない場合は、例外をスローします。 |
set_default_version |
PipelineEndpoint の既定のバージョンを設定します。指定したバージョンが見つからない場合は、例外をスローします。 |
set_name |
PipelineEndpoint の名前を設定します。 |
submit |
指定したバージョンのパイプライン実験を送信します。バージョンが none の場合は、パイプラインの既定のバージョンがトリガーされます。 |
add
指定したパイプラインを PipelineEndpoint に追加します。
add(pipeline)
パラメーター
名前 | 説明 |
---|---|
pipeline
必須
|
追加する公開されたパイプライン。 |
add_default
指定したパイプラインを PipelineEndpoint に追加し、既定のバージョンを、追加したパイプライン バージョンに設定します。
add_default(pipeline)
パラメーター
名前 | 説明 |
---|---|
pipeline
必須
|
既定のバージョンとして追加する公開されたパイプライン。 |
archive
PipelineEndpoint をアーカイブします。
archive()
disable
PipelineEndpoint を 'Disabled' に設定し、実行できないようにします。
disable()
enable
PipelineEndpoint を 'Active' に設定し、実行できるようにします。
enable()
get
名前または ID で PipelineEndpoint を取得します。どちらも指定されていない場合は例外をスローします。
static get(workspace, id=None, name=None, _workflow_provider=None, _service_endpoint=None)
パラメーター
名前 | 説明 |
---|---|
workspace
必須
|
PipelineEndpoint が作成されたワークスペース。 |
id
|
PipelineEndpoint の ID。 規定値: None
|
name
|
PipelineEndpoint の名前。 規定値: None
|
_workflow_provider
|
<xref:azureml.pipeline.core._aeva_provider._AevaWorkflowProvider>
ワークフロー プロバイダー。 規定値: None
|
_service_endpoint
|
サービス エンドポイント。 規定値: None
|
戻り値
型 | 説明 |
---|---|
PipelineEndpoint オブジェクト。 |
get_all
現在のワークスペース内のすべてのアクティブな PipelineEndpoint を取得します。
すべてのアクティブな PipelineEndpoint を取得します。 メモ: このメソッドは非推奨となる予定であり、PipelineEndpoint.list() が優先になります。
static get_all(workspace, active_only=True, _workflow_provider=None, _service_endpoint=None)
パラメーター
名前 | 説明 |
---|---|
workspace
必須
|
ワークスペース。 |
active_only
|
true の場合、現在アクティブな PipelineEndpoint のみを返します。 規定値: True
|
_workflow_provider
|
<xref:azureml.pipeline.core._aeva_provider._AevaWorkflowProvider>
ワークフロー プロバイダー。 規定値: None
|
_service_endpoint
|
サービス エンドポイント。 規定値: None
|
戻り値
型 | 説明 |
---|---|
PipelineEndpoint オブジェクトのリスト。 |
get_all_pipelines
PipelineEndpoint のパイプラインの一覧を取得します。
メモ: このメソッドは非推奨となる予定であり、list_pipelines() が優先になります
get_all_pipelines(active_only=True, _workflow_provider=None, _service_endpoint=None)
パラメーター
名前 | 説明 |
---|---|
active_only
|
アクティブな唯一のパイプラインを返すフラグ。 規定値: True
|
_workflow_provider
|
<xref:azureml.pipeline.core._aeva_provider._AevaWorkflowProvider>
ワークフロー プロバイダー。 規定値: None
|
_service_endpoint
|
サービス エンドポイント。 規定値: None
|
戻り値
型 | 説明 |
---|---|
PublishedPipeline オブジェクトのリスト。 |
get_all_versions
PipelineEndpoint のパイプラインおよび対応するバージョンの一覧を取得します。
メモ: このメソッドは非推奨となる予定であり、list_versions() が優先になります
get_all_versions(_workflow_provider=None, _service_endpoint=None)
パラメーター
名前 | 説明 |
---|---|
_workflow_provider
|
<xref:azureml.pipeline.core._aeva_provider._AevaWorkflowProvider>
ワークフロー プロバイダー。 規定値: None
|
_service_endpoint
|
サービス エンドポイント。 規定値: None
|
戻り値
型 | 説明 |
---|---|
PipelineVersion オブジェクトのリスト。 |
get_default_version
get_pipeline
指定したバージョンまたは既定のパイプラインを取得します。バージョンが見つからない場合は、例外をスローします。
get_pipeline(version=None)
パラメーター
名前 | 説明 |
---|---|
version
|
返されるパイプラインのバージョン。 規定値: None
|
戻り値
型 | 説明 |
---|---|
公開されたパイプライン。 |
list
現在のワークスペース内のアクティブな PipelineEndpoint を一覧表示します。
static list(workspace, active_only=True, max_results=100, _workflow_provider=None, _service_endpoint=None)
パラメーター
名前 | 説明 |
---|---|
workspace
必須
|
ワークスペース。 |
active_only
|
true の場合、現在アクティブな PipelineEndpoint のみを返します。 規定値: True
|
max_results
|
返される PipelineEndpoints の最大行数 規定値: 100
|
_workflow_provider
|
<xref:azureml.pipeline.core._aeva_provider._AevaWorkflowProvider>
ワークフロー プロバイダー。 規定値: None
|
_service_endpoint
|
サービス エンドポイント。 規定値: None
|
戻り値
型 | 説明 |
---|---|
PipelineEndpoint オブジェクトのリスト。 |
list_pipelines
PipelineEndpoint に関連付けられているパイプラインの一覧を取得します。
list_pipelines(active_only=True, _workflow_provider=None, _service_endpoint=None)
パラメーター
名前 | 説明 |
---|---|
active_only
|
アクティブなパイプラインのみを返すかどうかを示します。 規定値: True
|
_workflow_provider
|
<xref:azureml.pipeline.core._aeva_provider._AevaWorkflowProvider>
ワークフロー プロバイダー。 規定値: None
|
_service_endpoint
|
サービス エンドポイント。 規定値: None
|
戻り値
型 | 説明 |
---|---|
PublishedPipeline オブジェクトのリスト。 |
list_versions
PipelineEndpoint のパイプラインおよび対応するバージョンの一覧を取得します。
list_versions(_workflow_provider=None, _service_endpoint=None)
パラメーター
名前 | 説明 |
---|---|
_workflow_provider
|
<xref:azureml.pipeline.core._aeva_provider._AevaWorkflowProvider>
ワークフロー プロバイダー。 規定値: None
|
_service_endpoint
|
サービス エンドポイント。 規定値: None
|
戻り値
型 | 説明 |
---|---|
PipelineVersion オブジェクトのリスト。 |
publish
指定した名前とパイプラインまたは公開されたパイプラインを使用して、PipelineEndpoint を作成します。
パイプライン エンドポイントは、外部アプリケーションから使用できる REST API です。 REST エンドポイントを呼び出すときの認証方法については、https://aka.ms/pl-restep-auth を参照してください。
パイプライン エンドポイントの操作の詳細については、https://aka.ms/pl-first-pipeline を参照してください。
指定した名前の PipelineEndpoint が既に存在する場合は、例外をスローします。
static publish(workspace, name, description, pipeline, _workflow_provider=None, _service_endpoint=None)
パラメーター
名前 | 説明 |
---|---|
workspace
必須
|
PipelineEndpoint の作成先となるワークスペース。 |
name
必須
|
PipelineEndpoint の名前。 |
description
必須
|
PipelineEndpoint の説明。 |
pipeline
必須
|
公開されたパイプライン、またはパイプライン。 |
_service_endpoint
|
サービス エンドポイント。 規定値: None
|
_workflow_provider
|
<xref:azureml.pipeline.core._aeva_provider._AevaWorkflowProvider>
ワークフロー プロバイダー。 規定値: None
|
戻り値
型 | 説明 |
---|---|
新しい PipelineEndpoint。 |
例外
型 | 説明 |
---|---|
reactivate
アーカイブされた PipelineEndpoint を再アクティブ化します。
reactivate(name)
パラメーター
名前 | 説明 |
---|---|
name
必須
|
設定する名前。 |
戻り値
型 | 説明 |
---|---|
PipelineEndpoint オブジェクト。 |
set_default
PipelineEndpoint の既定のバージョンを設定します。指定したパイプラインが見つからない場合は、例外をスローします。
set_default(pipeline)
パラメーター
名前 | 説明 |
---|---|
pipeline
必須
|
既定として設定する公開されたパイプライン。 |
例外
型 | 説明 |
---|---|
set_default_version
PipelineEndpoint の既定のバージョンを設定します。指定したバージョンが見つからない場合は、例外をスローします。
set_default_version(version)
パラメーター
名前 | 説明 |
---|---|
version
必須
|
PipelineEndpoint で既定のバージョンとして設定するバージョン。 |
例外
型 | 説明 |
---|---|
set_name
submit
指定したバージョンのパイプライン実験を送信します。バージョンが none の場合は、パイプラインの既定のバージョンがトリガーされます。
submit(experiment_name, pipeline_parameters=None, parent_run_id=None, pipeline_version=None)
パラメーター
名前 | 説明 |
---|---|
experiment_name
必須
|
パイプラインを送信する実験の名前。 |
pipeline_parameters
|
パイプラインの実行で使用するパラメーター。{name: value} で表した辞書として渡します。 詳細については、 PipelineParameter をご覧ください。 規定値: None
|
parent_run_id
|
このパイプライン実行の親の実行に設定する実行 ID を指定できます。これは RunHistory に反映されます。 親の実行は、このパイプラインが送信されるのと同じ実験に属している必要があります。 規定値: None
|
pipeline_version
|
実行するパイプラインのバージョン。 規定値: None
|
戻り値
型 | 説明 |
---|---|
送信済みのパイプライン実行。 |
例外
型 | 説明 |
---|---|
属性
default_version
description
endpoint
PipelineEndpoint の REST エンドポイント URL を取得します。
エンドポイントは、パイプラインの実行をトリガーするために使用できます。
戻り値
型 | 説明 |
---|---|
パイプラインを実行する PipelineEndpoint の REST エンドポイント。 |
id
name
pipeline_version_list
status
swaggerurl
PipelineEndpoint の REST Swagger URL を取得します。
Swagger URL は、パイプライン エンドポイントのビュー スキーマである場合があります。
戻り値
型 | 説明 |
---|---|
パイプラインを実行する PipelineEndpoint の REST Swagger。 |