2 Copyright (c) 2015 SONATA-NFV and Paderborn University
5 Licensed under the Apache License, Version 2.0 (the "License");
6 you may not use this file except in compliance with the License.
7 You may obtain a copy of the License at
9 http://www.apache.org/licenses/LICENSE-2.0
11 Unless required by applicable law or agreed to in writing, software
12 distributed under the License is distributed on an "AS IS" BASIS,
13 WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
14 See the License for the specific language governing permissions and
15 limitations under the License.
17 Neither the name of the SONATA-NFV [, ANY ADDITIONAL AFFILIATION]
18 nor the names of its contributors may be used to endorse or promote
19 products derived from this software without specific prior written
22 This work has been performed in the framework of the SONATA project,
23 funded by the European Commission under Grant number 671517 through
24 the Horizon 2020 and 5G-PPP programmes. The authors would like to
25 acknowledge the contributions of their colleagues of the SONATA
26 partner consortium (www.sonata-nfv.eu).
29 from flask_restful
import Resource
30 from flask
import request
33 logging
.basicConfig(level
=logging
.INFO
)
38 class Compute(Resource
):
40 Start a new compute instance: A docker container (note: zerorpc does not support keyword arguments)
41 :param dc_label: name of the DC
42 :param compute_name: compute container name
43 :param image: image name
44 :param command: command to execute
45 :param network: list of all interface of the vnf, with their parameters (id=id1,ip=x.x.x.x/x),...
46 example networks list({"id":"input","ip": "10.0.0.254/8"}, {"id":"output","ip": "11.0.0.254/24"})
47 :return: docker inspect dict of deployed docker
51 def put(self
, dc_label
, compute_name
, resource
=None, value
=None):
52 # check if resource update
53 if resource
and value
:
54 c
= self
._update
_resource
(dc_label
, compute_name
, resource
, value
)
55 return c
.getStatus(), 200
57 # deploy new container
58 # check if json data is a dict
62 elif type(data
) is not dict:
63 data
= json
.loads(request
.json
)
65 network
= data
.get("network")
66 nw_list
= self
._parse
_network
(network
)
67 image
= data
.get("image")
68 command
= data
.get("docker_command")
71 logging
.debug("API CALL: compute start")
72 c
= dcs
.get(dc_label
).startCompute(
73 compute_name
, image
=image
, command
=command
, network
=nw_list
)
74 # return docker inspect dict
75 return c
.getStatus(), 200
76 except Exception as ex
:
77 logging
.exception("API error.")
78 return ex
.message
, 500
80 def _update_resource(self
, dc_label
, compute_name
, resource
, value
):
81 #check if container exists
82 d
= dcs
.get(dc_label
).net
.getNodeByName(compute_name
)
84 cpu_period
= int(dcs
.get(dc_label
).net
.cpu_period
)
85 cpu_quota
= int(cpu_period
* float(value
))
86 #put default values back
90 d
.updateCpuLimit(cpu_period
=cpu_period
, cpu_quota
=cpu_quota
)
94 def get(self
, dc_label
, compute_name
):
96 logging
.debug("API CALL: compute status")
99 return dcs
.get(dc_label
).containers
.get(compute_name
).getStatus(), 200
100 except Exception as ex
:
101 logging
.exception("API error.")
102 return ex
.message
, 500
104 def delete(self
, dc_label
, compute_name
):
105 logging
.debug("API CALL: compute stop")
107 return dcs
.get(dc_label
).stopCompute(compute_name
), 200
108 except Exception as ex
:
109 logging
.exception("API error.")
110 return ex
.message
, 500
112 def _parse_network(self
, network_str
):
114 parse the options for all network interfaces of the vnf
115 :param network_str: (id=x,ip=x.x.x.x/x), ...
116 :return: list of dicts [{"id":x,"ip":"x.x.x.x/x"}, ...]
120 # TODO make this more robust with regex check
121 if network_str
is None:
124 networks
= network_str
[1:-1].split('),(')
126 nw_dict
= dict(tuple(e
.split('=')) for e
in nw
.split(','))
127 nw_list
.append(nw_dict
)
132 class ComputeList(Resource
):
135 def get(self
, dc_label
=None):
136 logging
.debug("API CALL: compute list")
138 if dc_label
is None or dc_label
== 'None':
139 # return list with all compute nodes in all DCs
141 for dc
in dcs
.itervalues():
142 all_containers
+= dc
.listCompute()
143 return [(c
.name
, c
.getStatus()) for c
in all_containers
], 200
145 # return list of compute nodes for specified DC
146 return [(c
.name
, c
.getStatus())
147 for c
in dcs
.get(dc_label
).listCompute()], 200
148 except Exception as ex
:
149 logging
.exception("API error.")
150 return ex
.message
, 500
153 class DatacenterList(Resource
):
157 logging
.debug("API CALL: datacenter list")
159 return [d
.getStatus() for d
in dcs
.itervalues()], 200
160 except Exception as ex
:
161 logging
.exception("API error.")
162 return ex
.message
, 500
165 class DatacenterStatus(Resource
):
168 def get(self
, dc_label
):
169 logging
.debug("API CALL: datacenter status")
171 return dcs
.get(dc_label
).getStatus(), 200
172 except Exception as ex
:
173 logging
.exception("API error.")
174 return ex
.message
, 500