-
Notifications
You must be signed in to change notification settings - Fork 0
/
noisyModel.py
33 lines (26 loc) · 1.09 KB
/
noisyModel.py
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
from clipper_admin import ClipperConnection, DockerContainerManager
from clipper_admin.deployers.pyspark import deploy_pyspark_model
from clipper_admin.deployers import python as python_deployer
clipper_conn = ClipperConnection(DockerContainerManager())
clipper_conn.start_clipper()
clipper_addr = clipper_conn.get_query_addr()
def preprocess(inputs):
inputArr = (inputs[0]).split(",")
floats = inputArr[:-1]
rounded = [round(float(i),1) for i in floats]
rounded.append(inputArr[-1])
output = [(str(rounded))[1:-1]]
return output
python_deployer.deploy_python_closure(
clipper_conn,
name="process-iris", # The name of the model in Clipper
version=1, # A unique identifier to assign to this model.
input_type="string", # The type of data the model function expects as input
func=preprocess # The model function to deploy
)
clipper_conn.register_application(
name="process-app",
input_type="strings",
default_output="-1",
slo_micros=9000000) #will return default value in 9 seconds
clipper_conn.link_model_to_app(app_name="process-app", model_name="process-iris")