๐Ÿ“ฆ yjhjstz / mnist-handwrite

๐Ÿ“„ main.py ยท 94 lines
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94import sys, os
import numpy as np
import requests
import tensorflow as tf
from flask import Flask, jsonify, render_template, request

from tensorflow_serving.apis import predict_pb2
sys.path.append("./gen_protos")
import caffe2_service_pb2
import utils


def inference_pytorch(input, url, token=''):
    spec = caffe2_service_pb2.ModelSpec()
    spec.name = 'mnist'

    request = caffe2_service_pb2.PredictRequest()
    response = caffe2_service_pb2.PredictResponse()
    request.model_spec.CopyFrom(spec)

    array = input.reshape(1,1,28,28).astype(np.float32)
    request.inputs['input_1'].CopyFrom(utils.NumpyArrayToCaffe2Tensor(array))
    data = request.SerializeToString()

    data_type = "application/proto"
    headers = {
        # !!! set content type 
        'content-type': data_type,
        # !!! replace your token
        'Authorization': "AppCode " + token
    }

    res = requests.post(url=url,
                        data=data,
                        headers=headers)
    if (res.status_code == 200 and res.headers['Content-Type'] == data_type):
        response.ParseFromString(res.content)
        v = response.outputs['0'].float_data
        return np.array(v).flatten().tolist()
    else:
        print(res.content)


def inference_tf(input, url, token=''):
    request = predict_pb2.PredictRequest()
    response = predict_pb2.PredictResponse()

    request.model_spec.name = 'mnist'
    request.model_spec.signature_name = 'predict_images'

    request.inputs['images'].CopyFrom(
        tf.make_tensor_proto(input, shape=[1, 784]))

    data = request.SerializeToString()

    data_type = "application/proto"
    headers = {
        # !!! set content type 
        'content-type': data_type,
        # !!! replace your token
        'Authorization': "AppCode " + token
    }

    res = requests.post(url, data, headers=headers, verify=False)
    if (res.status_code == 200 and res.headers['Content-Type'] == data_type):
        # print res.content
        response.ParseFromString(res.content)
        v = response.outputs['scores'].float_val
        return np.array(v).flatten().tolist()
    else:
        # handle error msg
        print(res.content)

# webapp
app = Flask(__name__)
app.config.from_pyfile('config.py')

@app.route('/api/mnist', methods=['POST'])
def mnist():
    #input = ((255 - np.array(request.json, dtype=np.uint8)) / 255.0).reshape(1, 784).astype(np.float32)
    input = (np.array(request.json, dtype=np.uint8) / 255.0).reshape(1, 784).astype(np.float32)
    output1 = inference_pytorch(input, app.config.get("PYTROCH_URL"), app.config.get("PYTROCH_TOKEN"))
    output2 = inference_tf(input, app.config.get("TF_URL"), app.config.get("TF_TOKEN"))
    return jsonify(results=[output1, output2])


@app.route('/')
def main():
    return render_template('index.html')


if __name__ == '__main__':
    app.run(debug=True,host='0.0.0.0', port=8080)