將現有的管線作業部署至批次端點

適用於：Azure CLI ml 延伸模組 v2 (目前)Python SDK azure-ai-ml v2 (目前)

批次終端點可讓您部署管線元件，提供一個在 Azure Machine Learning 中操作管線的便捷方法。 批次端點接受用於部署的管線元件。 不過，如果您已經有成功執行的管線作業，Azure Machine Learning 可以接受該作業作為批次端點的輸入，並自動為您建立管線元件。 在本文中，您將了解如何使用現有的管線作業作為批次部署的輸入。

您將了解：

• 執行並建立您想要部署的管線作業
• 從現有的作業建立批次部署
• 測試部署

關於此範例

在此範例中，我們將部署管線，其中包含列印 「hello world！」 的簡單命令作業。 我們指出要用於部署的現有管線作業，而不是在部署之前註冊管線元件。 Azure Machine Learning 接著會自動建立管線元件，並將其部署為批次端點管線元件部署。

本文中的範例是以 azureml-examples 存放庫中包含的程式碼範例為基礎。 若要在本機執行命令，而不需要複製/貼上 YAML 和其他檔案，請複製存放庫，然後將目錄變更為該資料夾：

Azure CLI

git clone https://github.com/Azure/azureml-examples --depth 1
cd azureml-examples/cli

Python

git clone https://github.com/Azure/azureml-examples --depth 1
cd azureml-examples/sdk/python

此範例的檔案位於:

cd endpoints/batch/deploy-pipelines/hello-batch

必要條件

遵循本文中的步驟之前，請確定您已滿足下列必要條件：

• Azure 訂用帳戶。 如果您沒有 Azure 訂用帳戶，請在開始前建立免費帳戶。 試用免費或付費版本的 Azure Machine Learning。

• Azure Machine Learning 工作區。 如果您沒有帳戶，請使用管理 Azure 機器學習 工作區一文中的步驟來建立一個工作區。

• 請確定您在工作區中具有下列權限：

  • 建立或管理批次端點和部署：使用允許 Microsoft.MachineLearningServices/workspaces/batchEndpoints/*的擁有者、參與者或自定義角色。

  • 在工作區資源群組中建立ARM部署：使用可在部署工作區的資源群組中使用擁有 Microsoft.Resources/deployments/write 者、參與者或自定義角色。

• 您必須安裝下列軟體，才能使用 Azure 機器學習：

  Azure CLI

  Azure CLI 和適用於 Azure Machine Learning 的 ml 擴充功能。

  az extension add -n ml
  

  注意

  批次端點的管線元件部署是在 Azure CLI 的 ml 擴充功能 2.7 版中引進。 使用 az extension update --name ml 來取得其最後一個版本。

  Python

  適用於 Python 的 Azure Machine Learning SDK。

  pip install azure-ai-ml
  

  注意

  類別 ModelBatchDeployment 和 PipelineComponentBatchDeployment 是在 SDK 1.7.0 版中引進。 使用 pip install -U azure-ai-ml 來取得其最後一個版本。

連線到您的工作區

工作區是 Azure Machine Learning 的最上層資源，其提供一個集中位置來處理您在使用 Azure Machine Learning 時建立的所有成品。 在本節中，我們將連線到您將執行部署工作的工作區。

Azure CLI

在下列程式碼中傳入訂用帳戶識別碼、工作區、位置和資源群組的值：

az account set --subscription <subscription>
az configure --defaults workspace=<workspace> group=<resource-group> location=<location>

Python

1. 匯入必要的程式庫：

   from azure.ai.ml import MLClient, Input, load_component
   from azure.ai.ml.entities import BatchEndpoint, ModelBatchDeployment, ModelBatchDeploymentSettings, PipelineComponentBatchDeployment, Model, AmlCompute, Data, BatchRetrySettings, CodeConfiguration, Environment, Data
   from azure.ai.ml.constants import AssetTypes, BatchDeploymentOutputAction
   from azure.ai.ml.dsl import pipeline
   from azure.identity import DefaultAzureCredential
   

2. 設定工作區詳細資料，並取得工作區的控制代碼：

   在下列程式碼中傳入訂用帳戶識別碼、工作區和資源群組的值:

   subscription_id = "<subscription>"
   resource_group = "<resource-group>"
   workspace = "<workspace>"
   
   ml_client = MLClient(DefaultAzureCredential(), subscription_id, resource_group, workspace)
   

執行您想要部署的管線作業

在本節中，我們會從執行管線作業開始:

Azure CLI

下列 pipeline-job.yml 檔案包含管線作業的設定:

pipeline-job.yml

$schema: https://azuremlschemas.azureedge.net/latest/pipelineJob.schema.json
type: pipeline

experiment_name: hello-pipeline-batch
display_name: hello-pipeline-batch-job
description: This job demonstrates how to run the a pipeline component in a pipeline job. You can use this example to test a component in an standalone job before deploying it in an endpoint.

compute: batch-cluster
component: hello-component/hello.yml

Python

載入管線元件，並將其具現化:

hello_batch = load_component(source="hello-component/hello.yml")
pipeline_job = hello_batch()

現在，我們將設定一些執行設定以執行測試。 本文假設您具有名爲 batch-cluster 的計算叢集。 您可以將叢集取代為您的名稱。

pipeline_job.settings.default_compute = "batch-cluster"
pipeline_job.settings.default_datastore = "workspaceblobstore"

建立管線作業:

Azure CLI

JOB_NAME=$(az ml job create -f pipeline-job.yml --query name -o tsv)

Python

pipeline_job_run = ml_client.jobs.create_or_update(
    pipeline_job, experiment_name="hello-batch-pipeline"
)
pipeline_job_run

建立批次端點

在部署管線作業之前，我們需要部署批次端點來裝載部署。

1. 提供端點的名稱。 批次端點的名稱在每個區域中都不得重複，因為該名稱會用於建構叫用 URI。 若要確保名稱不重複，請將任何尾端字元附加至下列程式碼中指定的名稱。

   Azure CLI

   ENDPOINT_NAME="hello-batch"
   

   Python

   endpoint_name="hello-batch"
   

2. 設定端點：

   Azure CLI

   endpoint.yml 檔案包含端點的設定。

   endpoint.yml

   $schema: https://azuremlschemas.azureedge.net/latest/batchEndpoint.schema.json
   name: hello-batch
   description: A hello world endpoint for component deployments.
   auth_mode: aad_token
   

   Python

   endpoint = BatchEndpoint(
       name=endpoint_name,
       description="A hello world endpoint for component deployments",
   )
   

3. 建立端點：

   Azure CLI

   az ml batch-endpoint create --name $ENDPOINT_NAME  -f endpoint.yml
   

   Python

   ml_client.batch_endpoints.begin_create_or_update(endpoint).result()
   

4. 查詢端點 URI：

   Azure CLI

   az ml batch-endpoint show --name $ENDPOINT_NAME
   

   Python

   endpoint = ml_client.batch_endpoints.get(name=endpoint_name)
   print(endpoint)
   

部署管線作業

若要部署管線元件，我們必須從目前的作業建立批次部署。

1. 我們需要告訴 Azure Machine Learning 我們想要部署的作業名稱。 在我們的案例中，該作業會在下列變數中指出:

   Azure CLI

   echo $JOB_NAME
   

   Python

   print(job.name)
   

2. 設定部署。

   Azure CLI

   deployment-from-job.yml 檔案包含部署的設定。 請注意，我們如何使用密鑰 job_definition，而不是使用 component，來指出此部署是從管線作業建立的:

   deployment-from-job.yml

   $schema: https://azuremlschemas.azureedge.net/latest/pipelineComponentBatchDeployment.schema.json
   name: hello-batch-from-job
   endpoint_name: hello-pipeline-batch
   type: pipeline
   job_definition: azureml:job_name_placeholder
   settings:
       continue_on_step_failure: false
       default_compute: batch-cluster
   

   Python

   請注意，我們現在如何使用屬性 job_definition，而不是使用 component:

   deployment = PipelineComponentBatchDeployment(
       name="hello-batch-from-job",
       description="A hello world deployment with a single step. This deployment is created from a pipeline job.",
       endpoint_name=endpoint.name,
       job_definition=pipeline_job_run,
       settings={
           "default_compute": "batch-cluster",
           "continue_on_step_failure": False
       }
   )
   

   提示

   此設定假設您具有名爲 batch-cluster 的計算叢集。 您可以將此值取代為您叢集的名稱。

3. 建立部署：

   Azure CLI

   執行下列程式碼，在批次端點下建立批次部署，並將其設定為預設部署。

   az ml batch-deployment create --endpoint $ENDPOINT_NAME --set job_definition=azureml:$JOB_NAME -f deployment-from-job.yml
   

   提示

   請注意，使用 --set job_definition=azureml:$JOB_NAME。 由於作業名稱是唯一的，所以當您在工作區中執行作業時，會在這裡使用命令 --set 來變更作業的名稱。

   Python

   此命令會啟動部署建立，並在部署建立繼續時傳回確認回應。

   ml_client.batch_deployments.begin_create_or_update(deployment).result()
   

   建立之後，讓我們將這項新部署設定為預設部署:

   endpoint = ml_client.batch_endpoints.get(endpoint.name)
   endpoint.defaults.deployment_name = deployment.name
   ml_client.batch_endpoints.begin_create_or_update(endpoint).result()
   

4. 您的部署已可供使用。

測試部署

建立部署後，即可接收作業。 您可以叫用預設部署，如下所示:

Azure CLI

JOB_NAME=$(az ml batch-endpoint invoke -n $ENDPOINT_NAME --query name -o tsv)

Python

job = ml_client.batch_endpoints.invoke(
    endpoint_name=endpoint.name, 
)

您可以使用以下方式來監視顯示進度及串流記錄:

Azure CLI

az ml job stream -n $JOB_NAME

Python

ml_client.jobs.get(name=job.name)

若要等候作業完成，請執行下列程式碼:

ml_client.jobs.stream(name=job.name)

清除資源

完成後，請從工作區中刪除相關聯的資源:

Azure CLI

執行下列程式碼，以刪除批次端點及其基礎部署。 --yes 用來確認刪除。

az ml batch-endpoint delete -n $ENDPOINT_NAME --yes

Python

刪除端點：

ml_client.batch_endpoints.begin_delete(endpoint.name).result()

下一步

• 如何使用批次端點部署定型管線
• 如何透過前處理來部署管線以執行批次評分
• 從批次端點作業存取資料
• 針對批次端點進行疑難排解