Apache MXNet(incubating) recently announced support for Keras 2, we have already talked about some of the great features in this blog post. In this tutorial, we will walk you through one of the use cases where you can design your model, train using Keras-MXNet, and run inference in production, for example on Spark. We will use the latest Scala Inference API released with MXNet 1.2.0.
Train a ResNet-50 Model on CIFAR10 Dataset
Note: This functionality only supports models trained in channels first data format, which has better performance according to the keras-mxnet performance guide. Change
We will extend the work from our release blog post, please follow the instruction there for installation and training using multi GPUs. We used Keras example script to train a ResNet-50 Model on CIFAR10 Dataset .
For installation, if you are using GPU and have cuda 9.0 or above installed, just use the following command:
pip install mxnet-cu90
pip install keras-mxnet
If you have not cloned our repo, you can get the training script by using:
In order to save native MXNet models, add the following line at the end of your script. What happens under the hood is we are using native MXNet Module in Keras backend for better multi-GPU support, an extra perk doing that is you can save symbols and trained params in native MXNet format. For more details on how it works, please refer to Save MXNet model from Keras-MXNet.
data_names, data_shapes = save_mxnet_model(model=model, prefix='cifar10_resnet50', epoch=0)
Next, start the training script on N GPUs. (4 in our case, modify
num_gpus variable accordingly based on the GPUs you have)
After training finished at 100 epochs, you will see the following output:
Test loss: 1.13192281456
Test accuracy: 0.8308
MXNet Backend: Successfully exported the model as MXNet model!
MXNet symbol file - cifar10-resnet50-symbol.json
MXNet params file - cifar10-resnet50-0000.params
Model input data_names and data_shapes are:
data_names : ['/input_11']
data_shapes : [DataDesc[/input_11,(128L, 3L, 32L, 32L),float32,NCHW]]
At 100 epochs, we reached 83.08% test accuracy. Record the
data_shapes values as we will use them in the next part. Note that native MXNet model consists of two files, the
cifar10-resnet50-symbol.json file contains the symbolic graph and the
cifar10-resnet50-000.params records the parameters of the model.
Inference using MXNet Scala Inference API
Now it’s time to load the saved model and run inference. We will use the Scala Inference API released with MXNet 1.2.0. We will use the image classification example, and run our pre-trained model by just changing model names and input data shapes.
You should already have MXNet installed for Keras-MXNet to work, follow this tutorial to setup all other prerequisites for MXNet-Scala development:
- Install MXNet Scala Package
- IntelliJ IDE (or alternative IDE) project setup with the MXNet Scala Package
Prepare Model and Data
After setting up IntelliJ, we need to create two folders for model and inference data. For the model folder, place the two pre-trained model files there. In addition, we need to prepare a
synset.txt file that contains the label ID to label name mapping. For CIFAR10 dataset, it looks like the following:
In side the model folder
resnet-50, you will have:
For inference, we randomly saved 10 images from the CIFAR10 test dataset using a simple script in python and Keras. The output file name is in the fomat:
'x_test_index_label'. Run the following python script, and you will get the testing images.
from keras.datasets import cifar10(x_train, y_train),(x_test, y_test) = cifar10.load_data()
num_test = len(x_test)
num_images = 10
for idx in random.sample(range(0, num_test), num_images):
label = y_test[idx]
output = 'x_test_' + str(idx) + '_' + str(label) +'.jpg'
Load Pre-trained MXNet Model using Scala API
Now, we only need to load the image classifier example in IntelliJ and change a few lines (See complete modified code here). Remember the
data_shapes from the previous section? We need to pass them for MXNet to load the model, change line 47, 49, 68, 70 accordingly in the
runInferenceOnBatchOfImage methods. Since we are training and inference on the CIFAR10 dataset (32x32 size) in channel first format, change the
inputShape to (1, 3, 32, 32), and use the name
'/input_11' that we got from the
data_names variable in previous section.
val inputShape = Shape(1, 3, 32, 32)
val inputDescriptor = IndexedSeq(DataDesc("/input_11", inputShape, dType, "NCHW"))
runInferenceOnSingleImage method will look like the following, same rules applies to
To run the inference, we use the following 3 arguments:
1. The model file prefix we saved in training section
e.g. "/Users/lawei/scalaMXNet/models/resnet-50/cifar10-resnet50"2. Image to be predicted
e.g. "/Users/lawei/scalaMXNet/images/x_test_202_8.jpg"3. Directory of images to be predicted
Pass these arguments in IntelliJ, and then run the inference
You will get the following result, most of the testing images are predicted correctly. We are showing one example been predicted as horse (squint your eyes really hard, it is really a horse!):
Input image x_test_1584_7.jpg
Class with probability =Vector((7 horse,0.7975957), (3 cat,0.09379086), (4 deer,0.07512564), (0 airplane,0.032357983), (8 ship,4.789475E-4))
With the Scala API, you can run large scale inference on Spark, check out our tutorial and blog post for more details:
To learn more about the Scala API, read our medium blog posts series:
- CIFAR: “Learning Multiple Layers of Features from Tiny Images, Alex Krizhevsky, 2009.”
- ResNet: “Identity Mappings in Deep Residual Networks,Kaiming He, Xiangyu Zhang, Shaoqing Ren, Jian Sun, 2016.”
- ResNet: “Deep Residual Learning for Image Recognition, Kaiming He Xiangyu Zhang Shaoqing Ren Jian Sun, 2015”