title | description | services | ms.service | ms.component | ms.topic | ms.custom | author | ms.author | ms.reviewer | ms.date |
---|---|---|---|---|---|---|---|---|---|---|
Image classification tutorial: Deploy models with Azure Machine Learning service |
This tutorial shows how to use Azure Machine Learning service to deploy an image classification model with scikit-learn in a Python Jupyter notebook. This tutorial is part two of a two-part series. |
machine-learning |
machine-learning |
core |
tutorial |
seodec12 |
hning86 |
haining |
sgilley |
09/24/2018 |
This tutorial is part two of a two-part tutorial series. In the previous tutorial, you trained machine learning models and then registered a model in your workspace on the cloud.
Now, you're ready to deploy the model as a web service in Azure Container Instances (ACI). A web service is an image, in this case a Docker image, that encapsulates the scoring logic and the model itself.
In this part of the tutorial, you use Azure Machine Learning service to:
[!div class="checklist"]
- Set up your testing environment
- Retrieve the model from your workspace
- Test the model locally
- Deploy the model to ACI
- Test the deployed model
ACI is not ideal for production deployments, but it is great for testing and understanding the workflow. For scalable production deployments, consider using Azure Kubernetes Service.
For your convenience, this tutorial is available as a Jupyter notebook. Run the tutorials/img-classification-part2-deploy.ipynb
notebook either in Azure Notebooks or in your own Jupyter notebook server.
[!INCLUDE aml-clone-in-azure-notebook]
Note
Code in this article was tested with Azure Machine Learning SDK version 1.0.2
Complete the model training in the Tutorial #1: Train an image classification model with Azure Machine Learning service notebook.
Start by setting up a testing environment.
Import the Python packages needed for this tutorial.
%matplotlib inline
import numpy as np
import matplotlib
import matplotlib.pyplot as plt
import azureml
from azureml.core import Workspace, Run
# display the core SDK version number
print("Azure ML SDK Version: ", azureml.core.VERSION)
You registered a model in your workspace in the previous tutorial. Now, load this workspace and download the model to your local directory.
from azureml.core import Workspace
from azureml.core.model import Model
ws = Workspace.from_config()
model=Model(ws, 'sklearn_mnist')
model.download(target_dir = '.')
import os
# verify the downloaded model file
os.stat('./sklearn_mnist_model.pkl')
Before deploying, make sure your model is working locally by:
- Loading test data
- Predicting test data
- Examining the confusion matrix
Load the test data from the ./data/ directory created during the training tutorial.
from utils import load_data
# note we also shrink the intensity values (X) from 0-255 to 0-1. This helps the neural network converge faster
X_test = load_data('./data/test-images.gz', False) / 255.0
y_test = load_data('./data/test-labels.gz', True).reshape(-1)
Feed the test dataset to the model to get predictions.
import pickle
from sklearn.externals import joblib
clf = joblib.load('./sklearn_mnist_model.pkl')
y_hat = clf.predict(X_test)
Generate a confusion matrix to see how many samples from the test set are classified correctly. Notice the mis-classified value for the incorrect predictions.
from sklearn.metrics import confusion_matrix
conf_mx = confusion_matrix(y_test, y_hat)
print(conf_mx)
print('Overall accuracy:', np.average(y_hat == y_test))
The output shows the confusion matrix:
[[ 960 0 1 2 1 5 6 3 1 1]
[ 0 1112 3 1 0 1 5 1 12 0]
[ 9 8 920 20 10 4 10 11 37 3]
[ 4 0 17 921 2 21 4 12 20 9]
[ 1 2 5 3 915 0 10 2 6 38]
[ 10 2 0 41 10 770 17 7 28 7]
[ 9 3 7 2 6 20 907 1 3 0]
[ 2 7 22 5 8 1 1 950 5 27]
[ 10 15 5 21 15 27 7 11 851 12]
[ 7 8 2 13 32 13 0 24 12 898]]
Overall accuracy: 0.9204
Use matplotlib
to display the confusion matrix as a graph. In this graph, the X axis represents the actual values, and the Y axis represents the predicted values. The color in each grid represents the error rate. The lighter the color, the higher the error rate is. For example, many 5's are mis-classified as 3's. Hence you see a bright grid at (5,3).
# normalize the diagnal cells so that they don't overpower the rest of the cells when visualized
row_sums = conf_mx.sum(axis=1, keepdims=True)
norm_conf_mx = conf_mx / row_sums
np.fill_diagonal(norm_conf_mx, 0)
fig = plt.figure(figsize=(8,5))
ax = fig.add_subplot(111)
cax = ax.matshow(norm_conf_mx, cmap=plt.cm.bone)
ticks = np.arange(0, 10, 1)
ax.set_xticks(ticks)
ax.set_yticks(ticks)
ax.set_xticklabels(ticks)
ax.set_yticklabels(ticks)
fig.colorbar(cax)
plt.ylabel('true labels', fontsize=14)
plt.xlabel('predicted values', fontsize=14)
plt.savefig('conf.png')
plt.show()
Once you've tested the model and are satisfied with the results, deploy the model as a web service hosted in ACI.
To build the correct environment for ACI, provide the following:
- A scoring script to show how to use the model
- An environment file to show what packages need to be installed
- A configuration file to build the ACI
- The model you trained before
Create the scoring script, called score.py, used by the web service call to show how to use the model.
You must include two required functions into the scoring script:
-
The
init()
function, which typically loads the model into a global object. This function is run only once when the Docker container is started. -
The
run(input_data)
function uses the model to predict a value based on the input data. Inputs and outputs to the run typically use JSON for serialization and de-serialization, but other formats are supported.
%%writefile score.py
import json
import numpy as np
import os
import pickle
from sklearn.externals import joblib
from sklearn.linear_model import LogisticRegression
from azureml.core.model import Model
def init():
global model
# retreive the path to the model file using the model name
model_path = Model.get_model_path('sklearn_mnist')
model = joblib.load(model_path)
def run(raw_data):
data = np.array(json.loads(raw_data)['data'])
# make prediction
y_hat = model.predict(data)
return json.dumps(y_hat.tolist())
Next, create an environment file, called myenv.yml, that specifies all of the script's package dependencies. This file is used to ensure that all of those dependencies are installed in the Docker image. This model needs scikit-learn
and azureml-sdk
.
from azureml.core.conda_dependencies import CondaDependencies
myenv = CondaDependencies()
myenv.add_conda_package("scikit-learn")
with open("myenv.yml","w") as f:
f.write(myenv.serialize_to_string())
Review the content of the myenv.yml
file.
with open("myenv.yml","r") as f:
print(f.read())
Create a deployment configuration file and specify the number of CPUs and gigabyte of RAM needed for your ACI container. While it depends on your model, the default of 1 core and 1 gigabyte of RAM is usually sufficient for many models. If you feel you need more later, you would have to recreate the image and redeploy the service.
from azureml.core.webservice import AciWebservice
aciconfig = AciWebservice.deploy_configuration(cpu_cores=1,
memory_gb=1,
tags={"data": "MNIST", "method" : "sklearn"},
description='Predict MNIST with sklearn')
Estimated time to complete: about 7-8 minutes
Configure the image and deploy. The following code goes through these steps:
- Build an image using:
- The scoring file (
score.py
) - The environment file (
myenv.yml
) - The model file
- The scoring file (
- Register that image under the workspace.
- Send the image to the ACI container.
- Start up a container in ACI using the image.
- Get the web service HTTP endpoint.
%%time
from azureml.core.webservice import Webservice
from azureml.core.image import ContainerImage
# configure the image
image_config = ContainerImage.image_configuration(execution_script="score.py",
runtime="python",
conda_file="myenv.yml")
service = Webservice.deploy_from_model(workspace=ws,
name='sklearn-mnist-svc',
deployment_config=aciconfig,
models=[model],
image_config=image_config)
service.wait_for_deployment(show_output=True)
Get the scoring web service's HTTP endpoint, which accepts REST client calls. This endpoint can be shared with anyone who wants to test the web service or integrate it into an application.
print(service.scoring_uri)
Earlier you scored all the test data with the local version of the model. Now, you can test the deployed model with a random sample of 30 images from the test data.
The following code goes through these steps:
-
Send the data as a JSON array to the web service hosted in ACI.
-
Use the SDK's
run
API to invoke the service. You can also make raw calls using any HTTP tool such as curl. -
Print the returned predictions and plot them along with the input images. Red font and inverse image (white on black) is used to highlight the misclassified samples.
Since the model accuracy is high, you might have to run the following code a few times before you can see a misclassified sample.
import json
# find 30 random samples from test set
n = 30
sample_indices = np.random.permutation(X_test.shape[0])[0:n]
test_samples = json.dumps({"data": X_test[sample_indices].tolist()})
test_samples = bytes(test_samples, encoding = 'utf8')
# predict using the deployed model
result = json.loads(service.run(input_data=test_samples))
# compare actual value vs. the predicted values:
i = 0
plt.figure(figsize = (20, 1))
for s in sample_indices:
plt.subplot(1, n, i + 1)
plt.axhline('')
plt.axvline('')
# use different color for misclassified sample
font_color = 'red' if y_test[s] != result[i] else 'black'
clr_map = plt.cm.gray if y_test[s] != result[i] else plt.cm.Greys
plt.text(x=10, y =-10, s=result[i], fontsize=18, color=font_color)
plt.imshow(X_test[s].reshape(28, 28), cmap=clr_map)
i = i + 1
plt.show()
Here is the result of one random sample of test images:
You can also send raw HTTP request to test the web service.
import requests
import json
# send a random row from the test set to score
random_index = np.random.randint(0, len(X_test)-1)
input_data = "{\"data\": [" + str(list(X_test[random_index])) + "]}"
headers = {'Content-Type':'application/json'}
# for AKS deployment you'd need to the service key in the header as well
# api_key = service.get_key()
# headers = {'Content-Type':'application/json', 'Authorization':('Bearer '+ api_key)}
resp = requests.post(service.scoring_uri, input_data, headers=headers)
print("POST to url", service.scoring_uri)
#print("input data:", input_data)
print("label:", y_test[random_index])
print("prediction:", resp.text)
To keep the resource group and workspace for other tutorials and exploration, you can delete only the ACI deployment using this API call:
service.delete()
[!INCLUDE aml-delete-resource-group]
In this Azure Machine Learning service tutorial, you used Python to:
[!div class="checklist"]
- Set up your testing environment
- Retrieve the model from your workspace
- Test the model locally
- Deploy the model to ACI
- Test the deployed model
You can also try out the Automatic algorithm selection tutorial to see how Azure Machine Learning service can auto-select and tune the best algorithm for your model and build that model for you.