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 This module implements a simple REST API that behaves like SONATA's gatekeeper.
31 It is only used to support the development of SONATA's SDK tools and to demonstrate
32 the year 1 version of the emulator until the integration with WP4's orchestrator is done.
42 from docker
import DockerClient
, APIClient
43 from flask
import Flask
, request
44 import flask_restful
as fr
45 from collections
import defaultdict
47 from subprocess
import Popen
48 from random
import randint
52 LOG
= logging
.getLogger("sonata-dummy-gatekeeper")
53 LOG
.setLevel(logging
.DEBUG
)
54 logging
.getLogger("werkzeug").setLevel(logging
.WARNING
)
56 GK_STORAGE
= "/tmp/son-dummy-gk/"
57 UPLOAD_FOLDER
= os
.path
.join(GK_STORAGE
, "uploads/")
58 CATALOG_FOLDER
= os
.path
.join(GK_STORAGE
, "catalog/")
60 # Enable Dockerfile build functionality
61 BUILD_DOCKERFILE
= False
63 # flag to indicate that we run without the emulator (only the bare API for integration testing)
64 GK_STANDALONE_MODE
= False
66 # should a new version of an image be pulled even if its available
69 # Automatically deploy SAPs (endpoints) of the service as new containers
70 # Attention: This is not a configuration switch but a global variable! Don't change its default value.
73 # flag to indicate if we use bidirectional forwarding rules in the automatic chaining process
74 BIDIRECTIONAL_CHAIN
= False
76 # override the management interfaces in the descriptors with default docker0 interfaces in the containers
77 USE_DOCKER_MGMT
= True
79 def generate_subnets(prefix
, base
, subnet_size
=50, mask
=24):
80 # Generate a list of ipaddress in subnets
82 for net
in range(base
, base
+ subnet_size
):
83 subnet
= "{0}.{1}.0/{2}".format(prefix
, net
, mask
)
84 r
.append(ipaddress
.ip_network(unicode(subnet
)))
86 # private subnet definitions for the generated interfaces
88 SAP_SUBNETS
= generate_subnets('10.10', 0, subnet_size
=50, mask
=24)
90 ELAN_SUBNETS
= generate_subnets('10.20', 0, subnet_size
=50, mask
=24)
92 ELINE_SUBNETS
= generate_subnets('10.30', 0, subnet_size
=50, mask
=30)
95 class Gatekeeper(object):
98 self
.services
= dict()
101 self
.vnf_counter
= 0 # used to generate short names for VNFs (Mininet limitation)
102 LOG
.info("Create SONATA dummy gatekeeper.")
104 def register_service_package(self
, service_uuid
, service
):
106 register new service package
108 :param service object
110 self
.services
[service_uuid
] = service
111 # lets perform all steps needed to onboard the service
114 def get_next_vnf_name(self
):
115 self
.vnf_counter
+= 1
116 return "vnf%d" % self
.vnf_counter
119 class Service(object):
121 This class represents a NS uploaded as a *.son package to the
123 Can have multiple running instances of this service.
130 self
.uuid
= service_uuid
131 self
.package_file_hash
= package_file_hash
132 self
.package_file_path
= package_file_path
133 self
.package_content_path
= os
.path
.join(CATALOG_FOLDER
, "services/%s" % self
.uuid
)
138 self
.saps_ext
= list()
139 self
.saps_int
= list()
140 self
.local_docker_files
= dict()
141 self
.remote_docker_image_urls
= dict()
142 self
.instances
= dict()
143 self
.vnf_name2docker_name
= dict()
144 self
.vnf_id2vnf_name
= dict()
148 Do all steps to prepare this service to be instantiated
151 # 1. extract the contents of the package and store them in our catalog
152 self
._unpack
_service
_package
()
153 # 2. read in all descriptor files
154 self
._load
_package
_descriptor
()
159 # create dict to translate vnf names
160 self
.vnf_id2vnf_name
= defaultdict(lambda: "NotExistingNode",
161 reduce(lambda x
, y
: dict(x
, **y
),
162 map(lambda d
: {d
["vnf_id"]: d
["vnf_name"]},
163 self
.nsd
["network_functions"])))
164 # 3. prepare container images (e.g. download or build Dockerfile)
166 self
._load
_docker
_files
()
167 self
._build
_images
_from
_dockerfiles
()
169 self
._load
_docker
_urls
()
170 self
._pull
_predefined
_dockerimages
()
171 LOG
.info("On-boarded service: %r" % self
.manifest
.get("name"))
173 def start_service(self
):
175 This methods creates and starts a new service instance.
176 It computes placements, iterates over all VNFDs, and starts
177 each VNFD as a Docker container in the data center selected
178 by the placement algorithm.
181 LOG
.info("Starting service %r" % self
.uuid
)
183 # 1. each service instance gets a new uuid to identify it
184 instance_uuid
= str(uuid
.uuid4())
185 # build a instances dict (a bit like a NSR :))
186 self
.instances
[instance_uuid
] = dict()
187 self
.instances
[instance_uuid
]["vnf_instances"] = list()
189 # 2. compute placement of this service instance (adds DC names to VNFDs)
190 if not GK_STANDALONE_MODE
:
191 #self._calculate_placement(FirstDcPlacement)
192 self
._calculate
_placement
(RoundRobinDcPlacementWithSAPs
)
194 # 3. start all vnfds that we have in the service (except SAPs)
195 for vnfd
in self
.vnfds
.itervalues():
197 if not GK_STANDALONE_MODE
:
198 vnfi
= self
._start
_vnfd
(vnfd
)
199 self
.instances
[instance_uuid
]["vnf_instances"].append(vnfi
)
201 # 4. start all SAPs in the service
202 for sap
in self
.saps
:
203 self
._start
_sap
(self
.saps
[sap
], instance_uuid
)
205 # 5. Deploy E-Line and E_LAN links
206 if "virtual_links" in self
.nsd
:
207 vlinks
= self
.nsd
["virtual_links"]
208 # constituent virtual links are not checked
209 #fwd_links = self.nsd["forwarding_graphs"][0]["constituent_virtual_links"]
210 eline_fwd_links
= [l
for l
in vlinks
if (l
["connectivity_type"] == "E-Line")]
211 elan_fwd_links
= [l
for l
in vlinks
if (l
["connectivity_type"] == "E-LAN")]
213 GK
.net
.deployed_elines
.extend(eline_fwd_links
)
214 GK
.net
.deployed_elans
.extend(elan_fwd_links
)
216 # 5a. deploy E-Line links
217 self
._connect
_elines
(eline_fwd_links
, instance_uuid
)
219 # 5b. deploy E-LAN links
220 self
._connect
_elans
(elan_fwd_links
, instance_uuid
)
222 # 6. run the emulator specific entrypoint scripts in the VNFIs of this service instance
223 self
._trigger
_emulator
_start
_scripts
_in
_vnfis
(self
.instances
[instance_uuid
]["vnf_instances"])
225 LOG
.info("Service started. Instance id: %r" % instance_uuid
)
228 def stop_service(self
, instance_uuid
):
230 This method stops a running service instance.
231 It iterates over all VNF instances, stopping them each
232 and removing them from their data center.
234 :param instance_uuid: the uuid of the service instance to be stopped
236 LOG
.info("Stopping service %r" % self
.uuid
)
237 # get relevant information
238 # instance_uuid = str(self.uuid.uuid4())
239 vnf_instances
= self
.instances
[instance_uuid
]["vnf_instances"]
241 for v
in vnf_instances
:
244 if not GK_STANDALONE_MODE
:
246 # self._remove_placement(RoundRobinPlacement)
249 # last step: remove the instance from the list of all instances
250 del self
.instances
[instance_uuid
]
252 def _start_vnfd(self
, vnfd
):
254 Start a single VNFD of this service
255 :param vnfd: vnfd descriptor dict
258 # iterate over all deployment units within each VNFDs
259 for u
in vnfd
.get("virtual_deployment_units"):
260 # 1. get the name of the docker image to start and the assigned DC
261 vnf_name
= vnfd
.get("name")
262 if vnf_name
not in self
.remote_docker_image_urls
:
263 raise Exception("No image name for %r found. Abort." % vnf_name
)
264 docker_name
= self
.remote_docker_image_urls
.get(vnf_name
)
265 target_dc
= vnfd
.get("dc")
266 # 2. perform some checks to ensure we can start the container
267 assert(docker_name
is not None)
268 assert(target_dc
is not None)
269 if not self
._check
_docker
_image
_exists
(docker_name
):
270 raise Exception("Docker image %r not found. Abort." % docker_name
)
272 # 3. get the resource limits
273 res_req
= u
.get("resource_requirements")
274 cpu_list
= res_req
.get("cpu").get("cores")
275 if not cpu_list
or len(cpu_list
)==0:
277 cpu_bw
= res_req
.get("cpu").get("cpu_bw")
280 mem_num
= str(res_req
.get("memory").get("size"))
283 mem_unit
= str(res_req
.get("memory").get("size_unit"))
286 mem_limit
= float(mem_num
)
288 mem_limit
=mem_limit
*1024*1024*1024
290 mem_limit
=mem_limit
*1024*1024
292 mem_limit
=mem_limit
*1024
293 mem_lim
= int(mem_limit
)
294 cpu_period
, cpu_quota
= self
._calculate
_cpu
_cfs
_values
(float(cpu_bw
))
296 vnf_name2id
= defaultdict(lambda: "NotExistingNode",
297 reduce(lambda x
, y
: dict(x
, **y
),
298 map(lambda d
: {d
["vnf_name"]: d
["vnf_id"]},
299 self
.nsd
["network_functions"])))
301 # check if we need to deploy the management ports (defined as type:management both on in the vnfd and nsd)
302 intfs
= vnfd
.get("connection_points", [])
305 vnf_id
= vnf_name2id
[vnf_name
]
306 mgmt_intfs
= [vnf_id
+ ':' + intf
['id'] for intf
in intfs
if intf
.get('type') == 'management']
307 # check if any of these management interfaces are used in a management-type network in the nsd
308 for nsd_intf_name
in mgmt_intfs
:
309 vlinks
= [ l
["connection_points_reference"] for l
in self
.nsd
.get("virtual_links", [])]
311 if nsd_intf_name
in link
and self
.check_mgmt_interface(link
):
312 # this is indeed a management interface and can be skipped
313 vnf_id
, vnf_interface
, vnf_sap_docker_name
= parse_interface(nsd_intf_name
)
314 found_interfaces
= [intf
for intf
in intfs
if intf
.get('id') == vnf_interface
]
315 intfs
.remove(found_interfaces
[0])
316 mgmt_intf_names
.append(vnf_interface
)
318 # 4. generate the volume paths for the docker container
320 # a volume to extract log files
321 docker_log_path
= "/tmp/results/%s/%s"%(self
.uuid
,vnf_name
)
322 LOG
.debug("LOG path for vnf %s is %s."%(vnf_name
,docker_log_path
))
323 if not os
.path
.exists(docker_log_path
):
324 LOG
.debug("Creating folder %s"%docker
_log
_path
)
325 os
.makedirs(docker_log_path
)
327 volumes
.append(docker_log_path
+":/mnt/share/")
330 # 5. do the dc.startCompute(name="foobar") call to run the container
331 # TODO consider flavors, and other annotations
332 # TODO: get all vnf id's from the nsd for this vnfd and use those as dockername
333 # use the vnf_id in the nsd as docker name
334 # so deployed containers can be easily mapped back to the nsd
336 self
.vnf_name2docker_name
[vnf_name
] = vnf_name2id
[vnf_name
]
338 LOG
.info("Starting %r as %r in DC %r" % (vnf_name
, self
.vnf_name2docker_name
[vnf_name
], vnfd
.get("dc")))
339 LOG
.debug("Interfaces for %r: %r" % (vnf_name
, intfs
))
340 vnfi
= target_dc
.startCompute(
341 self
.vnf_name2docker_name
[vnf_name
],
346 cpu_period
=cpu_period
,
351 # rename the docker0 interfaces (eth0) to the management port name defined in the VNFD
353 for intf_name
in mgmt_intf_names
:
354 self
._vnf
_reconfigure
_network
(vnfi
, 'eth0', new_name
=intf_name
)
358 def _stop_vnfi(self
, vnfi
):
362 :param vnfi: vnf instance to be stopped
364 # Find the correct datacenter
365 status
= vnfi
.getStatus()
369 LOG
.info("Stopping the vnf instance contained in %r in DC %r" % (status
["name"], dc
))
370 dc
.stopCompute(status
["name"])
372 def _get_vnf_instance(self
, instance_uuid
, name
):
374 Returns the Docker object for the given VNF name (or Docker name).
375 :param instance_uuid: UUID of the service instance to search in.
376 :param name: VNF name or Docker name. We are fuzzy here.
380 if name
in self
.vnf_name2docker_name
:
381 dn
= self
.vnf_name2docker_name
[name
]
382 for vnfi
in self
.instances
[instance_uuid
]["vnf_instances"]:
385 LOG
.warning("No container with name: {0} found.".format(dn
))
389 def _vnf_reconfigure_network(vnfi
, if_name
, net_str
=None, new_name
=None):
391 Reconfigure the network configuration of a specific interface
392 of a running container.
393 :param vnfi: container instance
394 :param if_name: interface name
395 :param net_str: network configuration string, e.g., 1.2.3.4/24
399 # assign new ip address
400 if net_str
is not None:
401 intf
= vnfi
.intf(intf
=if_name
)
404 LOG
.debug("Reconfigured network of %s:%s to %r" % (vnfi
.name
, if_name
, net_str
))
406 LOG
.warning("Interface not found: %s:%s. Network reconfiguration skipped." % (vnfi
.name
, if_name
))
408 if new_name
is not None:
409 vnfi
.cmd('ip link set', if_name
, 'down')
410 vnfi
.cmd('ip link set', if_name
, 'name', new_name
)
411 vnfi
.cmd('ip link set', new_name
, 'up')
412 LOG
.debug("Reconfigured interface name of %s:%s to %s" % (vnfi
.name
, if_name
, new_name
))
416 def _trigger_emulator_start_scripts_in_vnfis(self
, vnfi_list
):
417 for vnfi
in vnfi_list
:
418 config
= vnfi
.dcinfo
.get("Config", dict())
419 env
= config
.get("Env", list())
421 var
, cmd
= map(str.strip
, map(str, env_var
.split('=', 1)))
422 LOG
.debug("%r = %r" % (var
, cmd
))
423 if var
=="SON_EMU_CMD":
424 LOG
.info("Executing entry point script in %r: %r" % (vnfi
.name
, cmd
))
425 # execute command in new thread to ensure that GK is not blocked by VNF
426 t
= threading
.Thread(target
=vnfi
.cmdPrint
, args
=(cmd
,))
430 def _unpack_service_package(self
):
432 unzip *.son file and store contents in CATALOG_FOLDER/services/<service_uuid>/
434 LOG
.info("Unzipping: %r" % self
.package_file_path
)
435 with zipfile
.ZipFile(self
.package_file_path
, "r") as z
:
436 z
.extractall(self
.package_content_path
)
439 def _load_package_descriptor(self
):
441 Load the main package descriptor YAML and keep it as dict.
444 self
.manifest
= load_yaml(
446 self
.package_content_path
, "META-INF/MANIFEST.MF"))
450 Load the entry NSD YAML and keep it as dict.
453 if "entry_service_template" in self
.manifest
:
454 nsd_path
= os
.path
.join(
455 self
.package_content_path
,
456 make_relative_path(self
.manifest
.get("entry_service_template")))
457 self
.nsd
= load_yaml(nsd_path
)
458 GK
.net
.deployed_nsds
.append(self
.nsd
)
460 LOG
.debug("Loaded NSD: %r" % self
.nsd
.get("name"))
462 def _load_vnfd(self
):
464 Load all VNFD YAML files referenced in MANIFEST.MF and keep them in dict.
467 if "package_content" in self
.manifest
:
468 for pc
in self
.manifest
.get("package_content"):
469 if pc
.get("content-type") == "application/sonata.function_descriptor":
470 vnfd_path
= os
.path
.join(
471 self
.package_content_path
,
472 make_relative_path(pc
.get("name")))
473 vnfd
= load_yaml(vnfd_path
)
474 self
.vnfds
[vnfd
.get("name")] = vnfd
475 LOG
.debug("Loaded VNFD: %r" % vnfd
.get("name"))
477 def _load_saps(self
):
478 # create list of all SAPs
479 # check if we need to deploy management ports
481 LOG
.debug("nsd: {0}".format(self
.nsd
))
482 SAPs
= [p
for p
in self
.nsd
["connection_points"] if 'management' not in p
.get('type')]
484 SAPs
= [p
for p
in self
.nsd
["connection_points"]]
487 # endpoint needed in this service
488 sap_id
, sap_interface
, sap_docker_name
= parse_interface(sap
['id'])
489 # make sure SAP has type set (default internal)
490 sap
["type"] = sap
.get("type", 'internal')
492 # Each Service Access Point (connection_point) in the nsd is an IP address on the host
493 if sap
["type"] == "external":
494 # add to vnfds to calculate placement later on
495 sap_net
= SAP_SUBNETS
.pop(0)
496 self
.saps
[sap_docker_name
] = {"name": sap_docker_name
, "type": "external", "net": sap_net
}
497 # add SAP vnf to list in the NSD so it is deployed later on
498 # each SAP get a unique VNFD and vnf_id in the NSD and custom type (only defined in the dummygatekeeper)
499 self
.nsd
["network_functions"].append(
500 {"vnf_id": sap_docker_name
, "vnf_name": sap_docker_name
, "vnf_type": "sap_ext"})
502 # Each Service Access Point (connection_point) in the nsd is getting its own container (default)
503 elif sap
["type"] == "internal" or sap
["type"] == "management":
504 # add SAP to self.vnfds
505 sapfile
= pkg_resources
.resource_filename(__name__
, "sap_vnfd.yml")
506 sap_vnfd
= load_yaml(sapfile
)
507 sap_vnfd
["connection_points"][0]["id"] = sap_interface
508 sap_vnfd
["name"] = sap_docker_name
509 sap_vnfd
["type"] = "internal"
510 # add to vnfds to calculate placement later on and deploy
511 self
.saps
[sap_docker_name
] = sap_vnfd
512 # add SAP vnf to list in the NSD so it is deployed later on
513 # each SAP get a unique VNFD and vnf_id in the NSD
514 self
.nsd
["network_functions"].append(
515 {"vnf_id": sap_docker_name
, "vnf_name": sap_docker_name
, "vnf_type": "sap_int"})
517 LOG
.debug("Loaded SAP: name: {0}, type: {1}".format(sap_docker_name
, sap
['type']))
520 self
.saps_ext
= [self
.saps
[sap
]['name'] for sap
in self
.saps
if self
.saps
[sap
]["type"] == "external"]
521 self
.saps_int
= [self
.saps
[sap
]['name'] for sap
in self
.saps
if self
.saps
[sap
]["type"] == "internal"]
523 def _start_sap(self
, sap
, instance_uuid
):
527 LOG
.info('start SAP: {0} ,type: {1}'.format(sap
['name'],sap
['type']))
528 if sap
["type"] == "internal":
530 if not GK_STANDALONE_MODE
:
531 vnfi
= self
._start
_vnfd
(sap
)
532 self
.instances
[instance_uuid
]["vnf_instances"].append(vnfi
)
534 elif sap
["type"] == "external":
535 target_dc
= sap
.get("dc")
536 # add interface to dc switch
537 target_dc
.attachExternalSAP(sap
['name'], str(sap
['net']))
539 def _connect_elines(self
, eline_fwd_links
, instance_uuid
):
541 Connect all E-LINE links in the NSD
542 :param eline_fwd_links: list of E-LINE links in the NSD
543 :param: instance_uuid of the service
546 # cookie is used as identifier for the flowrules installed by the dummygatekeeper
547 # eg. different services get a unique cookie for their flowrules
549 for link
in eline_fwd_links
:
550 # check if we need to deploy this link when its a management link:
552 if self
.check_mgmt_interface(link
["connection_points_reference"]):
555 src_id
, src_if_name
, src_sap_id
= parse_interface(link
["connection_points_reference"][0])
556 dst_id
, dst_if_name
, dst_sap_id
= parse_interface(link
["connection_points_reference"][1])
559 # check if there is a SAP in the link and chain everything together
560 if src_sap_id
in self
.saps
and dst_sap_id
in self
.saps
:
561 LOG
.info('2 SAPs cannot be chained together : {0} - {1}'.format(src_sap_id
, dst_sap_id
))
564 elif src_sap_id
in self
.saps_ext
:
566 src_if_name
= src_sap_id
567 src_name
= self
.vnf_id2vnf_name
[src_id
]
568 dst_name
= self
.vnf_id2vnf_name
[dst_id
]
569 dst_vnfi
= self
._get
_vnf
_instance
(instance_uuid
, dst_name
)
570 if dst_vnfi
is not None:
571 # choose first ip address in sap subnet
572 sap_net
= self
.saps
[src_sap_id
]['net']
573 sap_ip
= "{0}/{1}".format(str(sap_net
[1]), sap_net
.prefixlen
)
574 self
._vnf
_reconfigure
_network
(dst_vnfi
, dst_if_name
, sap_ip
)
577 elif dst_sap_id
in self
.saps_ext
:
579 dst_if_name
= dst_sap_id
580 src_name
= self
.vnf_id2vnf_name
[src_id
]
581 dst_name
= self
.vnf_id2vnf_name
[dst_id
]
582 src_vnfi
= self
._get
_vnf
_instance
(instance_uuid
, src_name
)
583 if src_vnfi
is not None:
584 sap_net
= self
.saps
[dst_sap_id
]['net']
585 sap_ip
= "{0}/{1}".format(str(sap_net
[1]), sap_net
.prefixlen
)
586 self
._vnf
_reconfigure
_network
(src_vnfi
, src_if_name
, sap_ip
)
589 # Link between 2 VNFs
591 # make sure we use the correct sap vnf name
592 if src_sap_id
in self
.saps_int
:
594 if dst_sap_id
in self
.saps_int
:
596 src_name
= self
.vnf_id2vnf_name
[src_id
]
597 dst_name
= self
.vnf_id2vnf_name
[dst_id
]
598 # re-configure the VNFs IP assignment and ensure that a new subnet is used for each E-Link
599 src_vnfi
= self
._get
_vnf
_instance
(instance_uuid
, src_name
)
600 dst_vnfi
= self
._get
_vnf
_instance
(instance_uuid
, dst_name
)
601 if src_vnfi
is not None and dst_vnfi
is not None:
602 eline_net
= ELINE_SUBNETS
.pop(0)
603 ip1
= "{0}/{1}".format(str(eline_net
[1]), eline_net
.prefixlen
)
604 ip2
= "{0}/{1}".format(str(eline_net
[2]), eline_net
.prefixlen
)
605 self
._vnf
_reconfigure
_network
(src_vnfi
, src_if_name
, ip1
)
606 self
._vnf
_reconfigure
_network
(dst_vnfi
, dst_if_name
, ip2
)
611 ret
= GK
.net
.setChain(
613 vnf_src_interface
=src_if_name
, vnf_dst_interface
=dst_if_name
,
614 bidirectional
=BIDIRECTIONAL_CHAIN
, cmd
="add-flow", cookie
=cookie
, priority
=10)
616 "Setting up E-Line link. %s(%s:%s) -> %s(%s:%s)" % (
617 src_name
, src_id
, src_if_name
, dst_name
, dst_id
, dst_if_name
))
620 def _connect_elans(self
, elan_fwd_links
, instance_uuid
):
622 Connect all E-LAN links in the NSD
623 :param elan_fwd_links: list of E-LAN links in the NSD
624 :param: instance_uuid of the service
627 for link
in elan_fwd_links
:
628 # check if we need to deploy this link when its a management link:
630 if self
.check_mgmt_interface(link
["connection_points_reference"]):
634 # check if an external SAP is in the E-LAN (then a subnet is already defined)
635 intfs_elan
= [intf
for intf
in link
["connection_points_reference"]]
636 lan_sap
= self
.check_ext_saps(intfs_elan
)
638 lan_net
= self
.saps
[lan_sap
]['net']
639 lan_hosts
= list(lan_net
.hosts())
640 sap_ip
= str(lan_hosts
.pop(0))
642 lan_net
= ELAN_SUBNETS
.pop(0)
643 lan_hosts
= list(lan_net
.hosts())
645 # generate lan ip address for all interfaces except external SAPs
646 for intf
in link
["connection_points_reference"]:
648 # skip external SAPs, they already have an ip
649 vnf_id
, vnf_interface
, vnf_sap_docker_name
= parse_interface(intf
)
650 if vnf_sap_docker_name
in self
.saps_ext
:
651 elan_vnf_list
.append({'name': vnf_sap_docker_name
, 'interface': vnf_interface
})
654 ip_address
= "{0}/{1}".format(str(lan_hosts
.pop(0)), lan_net
.prefixlen
)
655 vnf_id
, intf_name
, vnf_sap_id
= parse_interface(intf
)
657 # make sure we use the correct sap vnf name
658 src_docker_name
= vnf_id
659 if vnf_sap_id
in self
.saps_int
:
660 src_docker_name
= vnf_sap_id
663 vnf_name
= self
.vnf_id2vnf_name
[vnf_id
]
665 "Setting up E-LAN interface. %s(%s:%s) -> %s" % (
666 vnf_name
, vnf_id
, intf_name
, ip_address
))
668 if vnf_name
in self
.vnfds
:
669 # re-configure the VNFs IP assignment and ensure that a new subnet is used for each E-LAN
670 # E-LAN relies on the learning switch capability of Ryu which has to be turned on in the topology
671 # (DCNetwork(controller=RemoteController, enable_learning=True)), so no explicit chaining is necessary.
672 vnfi
= self
._get
_vnf
_instance
(instance_uuid
, vnf_name
)
674 self
._vnf
_reconfigure
_network
(vnfi
, intf_name
, ip_address
)
675 # add this vnf and interface to the E-LAN for tagging
676 elan_vnf_list
.append({'name': src_docker_name
, 'interface': intf_name
})
678 # install the VLAN tags for this E-LAN
679 GK
.net
.setLAN(elan_vnf_list
)
682 def _load_docker_files(self
):
684 Get all paths to Dockerfiles from VNFDs and store them in dict.
687 for k
, v
in self
.vnfds
.iteritems():
688 for vu
in v
.get("virtual_deployment_units"):
689 if vu
.get("vm_image_format") == "docker":
690 vm_image
= vu
.get("vm_image")
691 docker_path
= os
.path
.join(
692 self
.package_content_path
,
693 make_relative_path(vm_image
))
694 self
.local_docker_files
[k
] = docker_path
695 LOG
.debug("Found Dockerfile (%r): %r" % (k
, docker_path
))
697 def _load_docker_urls(self
):
699 Get all URLs to pre-build docker images in some repo.
702 # also merge sap dicts, because internal saps also need a docker container
703 all_vnfs
= self
.vnfds
.copy()
704 all_vnfs
.update(self
.saps
)
706 for k
, v
in all_vnfs
.iteritems():
707 for vu
in v
.get("virtual_deployment_units", {}):
708 if vu
.get("vm_image_format") == "docker":
709 url
= vu
.get("vm_image")
711 url
= url
.replace("http://", "")
712 self
.remote_docker_image_urls
[k
] = url
713 LOG
.debug("Found Docker image URL (%r): %r" % (k
, self
.remote_docker_image_urls
[k
]))
715 def _build_images_from_dockerfiles(self
):
717 Build Docker images for each local Dockerfile found in the package: self.local_docker_files
719 if GK_STANDALONE_MODE
:
720 return # do not build anything in standalone mode
722 LOG
.info("Building %d Docker images (this may take several minutes) ..." % len(self
.local_docker_files
))
723 for k
, v
in self
.local_docker_files
.iteritems():
724 for line
in dc
.build(path
=v
.replace("Dockerfile", ""), tag
=k
, rm
=False, nocache
=False):
725 LOG
.debug("DOCKER BUILD: %s" % line
)
726 LOG
.info("Docker image created: %s" % k
)
728 def _pull_predefined_dockerimages(self
):
730 If the package contains URLs to pre-build Docker images, we download them with this method.
733 for url
in self
.remote_docker_image_urls
.itervalues():
734 if not FORCE_PULL
: # only pull if not present (speedup for development)
735 if len(dc
.images
.list(name
=url
)) > 0:
736 LOG
.debug("Image %r present. Skipping pull." % url
)
738 LOG
.info("Pulling image: %r" % url
)
739 # this seems to fail with latest docker api version 2.0.2
740 # dc.images.pull(url,
741 # insecure_registry=True)
742 #using docker cli instead
752 def _check_docker_image_exists(self
, image_name
):
754 Query the docker service and check if the given image exists
755 :param image_name: name of the docker image
758 return len(DockerClient().images
.list(name
=image_name
)) > 0
760 def _calculate_placement(self
, algorithm
):
762 Do placement by adding the a field "dc" to
763 each VNFD that points to one of our
764 data center objects known to the gatekeeper.
766 assert(len(self
.vnfds
) > 0)
767 assert(len(GK
.dcs
) > 0)
768 # instantiate algorithm an place
770 p
.place(self
.nsd
, self
.vnfds
, self
.saps
, GK
.dcs
)
771 LOG
.info("Using placement algorithm: %r" % p
.__class
__.__name
__)
772 # lets print the placement result
773 for name
, vnfd
in self
.vnfds
.iteritems():
774 LOG
.info("Placed VNF %r on DC %r" % (name
, str(vnfd
.get("dc"))))
775 for sap
in self
.saps
:
776 sap_dict
= self
.saps
[sap
]
777 LOG
.info("Placed SAP %r on DC %r" % (sap
, str(sap_dict
.get("dc"))))
780 def _calculate_cpu_cfs_values(self
, cpu_time_percentage
):
782 Calculate cpu period and quota for CFS
783 :param cpu_time_percentage: percentage of overall CPU to be used
784 :return: cpu_period, cpu_quota
786 if cpu_time_percentage
is None:
788 if cpu_time_percentage
< 0:
790 # (see: https://www.kernel.org/doc/Documentation/scheduler/sched-bwc.txt)
791 # Attention minimum cpu_quota is 1ms (micro)
792 cpu_period
= 1000000 # lets consider a fixed period of 1000000 microseconds for now
793 LOG
.debug("cpu_period is %r, cpu_percentage is %r" % (cpu_period
, cpu_time_percentage
))
794 cpu_quota
= cpu_period
* cpu_time_percentage
# calculate the fraction of cpu time for this container
795 # ATTENTION >= 1000 to avoid a invalid argument system error ... no idea why
797 LOG
.debug("cpu_quota before correcting: %r" % cpu_quota
)
799 LOG
.warning("Increased CPU quota to avoid system error.")
800 LOG
.debug("Calculated: cpu_period=%f / cpu_quota=%f" % (cpu_period
, cpu_quota
))
801 return int(cpu_period
), int(cpu_quota
)
803 def check_ext_saps(self
, intf_list
):
804 # check if the list of interfacs contains an externl SAP
805 saps_ext
= [self
.saps
[sap
]['name'] for sap
in self
.saps
if self
.saps
[sap
]["type"] == "external"]
806 for intf_name
in intf_list
:
807 vnf_id
, vnf_interface
, vnf_sap_docker_name
= parse_interface(intf_name
)
808 if vnf_sap_docker_name
in saps_ext
:
809 return vnf_sap_docker_name
811 def check_mgmt_interface(self
, intf_list
):
812 SAPs_mgmt
= [p
.get('id') for p
in self
.nsd
["connection_points"] if 'management' in p
.get('type')]
813 for intf_name
in intf_list
:
814 if intf_name
in SAPs_mgmt
:
818 Some (simple) placement algorithms
822 class FirstDcPlacement(object):
824 Placement: Always use one and the same data center from the GK.dcs dict.
826 def place(self
, nsd
, vnfds
, saps
, dcs
):
827 for name
, vnfd
in vnfds
.iteritems():
828 vnfd
["dc"] = list(dcs
.itervalues())[0]
831 class RoundRobinDcPlacement(object):
833 Placement: Distribute VNFs across all available DCs in a round robin fashion.
835 def place(self
, nsd
, vnfds
, saps
, dcs
):
837 dcs_list
= list(dcs
.itervalues())
838 for name
, vnfd
in vnfds
.iteritems():
839 vnfd
["dc"] = dcs_list
[c
% len(dcs_list
)]
840 c
+= 1 # inc. c to use next DC
842 class RoundRobinDcPlacementWithSAPs(object):
844 Placement: Distribute VNFs across all available DCs in a round robin fashion,
845 every SAP is instantiated on the same DC as the connected VNF.
847 def place(self
, nsd
, vnfds
, saps
, dcs
):
851 dcs_list
= list(dcs
.itervalues())
852 for name
, vnfd
in vnfds
.iteritems():
853 vnfd
["dc"] = dcs_list
[c
% len(dcs_list
)]
854 c
+= 1 # inc. c to use next DC
857 vlinks
= nsd
.get("virtual_links", [])
858 eline_fwd_links
= [l
for l
in vlinks
if (l
["connectivity_type"] == "E-Line")]
859 elan_fwd_links
= [l
for l
in vlinks
if (l
["connectivity_type"] == "E-LAN")]
861 vnf_id2vnf_name
= defaultdict(lambda: "NotExistingNode",
862 reduce(lambda x
, y
: dict(x
, **y
),
863 map(lambda d
: {d
["vnf_id"]: d
["vnf_name"]},
864 nsd
["network_functions"])))
866 # SAPs on E-Line links are placed on the same DC as the VNF on the E-Line
867 for link
in eline_fwd_links
:
868 src_id
, src_if_name
, src_sap_id
= parse_interface(link
["connection_points_reference"][0])
869 dst_id
, dst_if_name
, dst_sap_id
= parse_interface(link
["connection_points_reference"][1])
871 # check if there is a SAP in the link
872 if src_sap_id
in saps
:
873 dst_vnf_name
= vnf_id2vnf_name
[dst_id
]
874 # get dc where connected vnf is mapped to
875 dc
= vnfds
[dst_vnf_name
]['dc']
876 saps
[src_sap_id
]['dc'] = dc
878 if dst_sap_id
in saps
:
879 src_vnf_name
= vnf_id2vnf_name
[src_id
]
880 # get dc where connected vnf is mapped to
881 dc
= vnfds
[src_vnf_name
]['dc']
882 saps
[dst_sap_id
]['dc'] = dc
884 # SAPs on E-LANs are placed on a random DC
885 dcs_list
= list(dcs
.itervalues())
886 dc_len
= len(dcs_list
)
887 for link
in elan_fwd_links
:
888 for intf
in link
["connection_points_reference"]:
889 # find SAP interfaces
890 intf_id
, intf_name
, intf_sap_id
= parse_interface(intf
)
891 if intf_sap_id
in saps
:
892 dc
= dcs_list
[randint(0, dc_len
-1)]
893 saps
[intf_sap_id
]['dc'] = dc
898 Resource definitions and API endpoints
902 class Packages(fr
.Resource
):
906 Upload a *.son service package to the dummy gatekeeper.
908 We expect request with a *.son file and store it in UPLOAD_FOLDER
913 LOG
.info("POST /packages called")
914 # lets search for the package in the request
915 is_file_object
= False # make API more robust: file can be in data or in files field
916 if "package" in request
.files
:
917 son_file
= request
.files
["package"]
918 is_file_object
= True
919 elif len(request
.data
) > 0:
920 son_file
= request
.data
922 return {"service_uuid": None, "size": 0, "sha1": None, "error": "upload failed. file not found."}, 500
923 # generate a uuid to reference this package
924 service_uuid
= str(uuid
.uuid4())
925 file_hash
= hashlib
.sha1(str(son_file
)).hexdigest()
926 # ensure that upload folder exists
927 ensure_dir(UPLOAD_FOLDER
)
928 upload_path
= os
.path
.join(UPLOAD_FOLDER
, "%s.son" % service_uuid
)
929 # store *.son file to disk
931 son_file
.save(upload_path
)
933 with
open(upload_path
, 'wb') as f
:
935 size
= os
.path
.getsize(upload_path
)
936 # create a service object and register it
937 s
= Service(service_uuid
, file_hash
, upload_path
)
938 GK
.register_service_package(service_uuid
, s
)
939 # generate the JSON result
940 return {"service_uuid": service_uuid
, "size": size
, "sha1": file_hash
, "error": None}, 201
941 except Exception as ex
:
942 LOG
.exception("Service package upload failed:")
943 return {"service_uuid": None, "size": 0, "sha1": None, "error": "upload failed"}, 500
947 Return a list of UUID's of uploaded service packages.
950 LOG
.info("GET /packages")
951 return {"service_uuid_list": list(GK
.services
.iterkeys())}
954 class Instantiations(fr
.Resource
):
958 Instantiate a service specified by its UUID.
959 Will return a new UUID to identify the running service instance.
962 LOG
.info("POST /instantiations (or /requests) called")
963 # try to extract the service uuid from the request
964 json_data
= request
.get_json(force
=True)
965 service_uuid
= json_data
.get("service_uuid")
967 # lets be a bit fuzzy here to make testing easier
968 if (service_uuid
is None or service_uuid
=="latest") and len(GK
.services
) > 0:
969 # if we don't get a service uuid, we simple start the first service in the list
970 service_uuid
= list(GK
.services
.iterkeys())[0]
971 if service_uuid
in GK
.services
:
972 # ok, we have a service uuid, lets start the service
973 service_instance_uuid
= GK
.services
.get(service_uuid
).start_service()
974 return {"service_instance_uuid": service_instance_uuid
}, 201
975 return "Service not found", 404
979 Returns a list of UUIDs containing all running services.
982 LOG
.info("GET /instantiations")
983 return {"service_instantiations_list": [
984 list(s
.instances
.iterkeys()) for s
in GK
.services
.itervalues()]}
988 Stops a running service specified by its service and instance UUID.
990 # try to extract the service and instance UUID from the request
991 json_data
= request
.get_json(force
=True)
992 service_uuid
= json_data
.get("service_uuid")
993 instance_uuid
= json_data
.get("service_instance_uuid")
996 if service_uuid
is None and len(GK
.services
) > 0:
997 #if we don't get a service uuid, we simply stop the last service in the list
998 service_uuid
= list(GK
.services
.iterkeys())[0]
999 if instance_uuid
is None and len(GK
.services
[service_uuid
].instances
) > 0:
1000 instance_uuid
= list(GK
.services
[service_uuid
].instances
.iterkeys())[0]
1002 if service_uuid
in GK
.services
and instance_uuid
in GK
.services
[service_uuid
].instances
:
1003 # valid service and instance UUID, stop service
1004 GK
.services
.get(service_uuid
).stop_service(instance_uuid
)
1005 return "service instance with uuid %r stopped." % instance_uuid
,200
1006 return "Service not found", 404
1008 class Exit(fr
.Resource
):
1012 Stop the running Containernet instance regardless of data transmitted
1014 list(GK
.dcs
.values())[0].net
.stop()
1017 def initialize_GK():
1023 # create a single, global GK object
1027 app
= Flask(__name__
)
1028 app
.config
['MAX_CONTENT_LENGTH'] = 512 * 1024 * 1024 # 512 MB max upload
1031 api
.add_resource(Packages
, '/packages', '/api/v2/packages')
1032 api
.add_resource(Instantiations
, '/instantiations', '/api/v2/instantiations', '/api/v2/requests')
1033 api
.add_resource(Exit
, '/emulator/exit')
1037 def start_rest_api(host
, port
, datacenters
=dict()):
1038 GK
.dcs
= datacenters
1039 GK
.net
= get_dc_network()
1040 # start the Flask server (not the best performance but ok for our use case)
1044 use_reloader
=False # this is needed to run Flask in a non-main thread
1048 def ensure_dir(name
):
1049 if not os
.path
.exists(name
):
1053 def load_yaml(path
):
1054 with
open(path
, "r") as f
:
1057 except yaml
.YAMLError
as exc
:
1058 LOG
.exception("YAML parse error")
1063 def make_relative_path(path
):
1064 if path
.startswith("file://"):
1065 path
= path
.replace("file://", "", 1)
1066 if path
.startswith("/"):
1067 path
= path
.replace("/", "", 1)
1071 def get_dc_network():
1073 retrieve the DCnetwork where this dummygatekeeper (GK) connects to.
1074 Assume at least 1 datacenter is connected to this GK, and that all datacenters belong to the same DCNetwork
1077 assert (len(GK
.dcs
) > 0)
1078 return GK
.dcs
.values()[0].net
1081 def parse_interface(interface_name
):
1083 convert the interface name in the nsd to the according vnf_id, vnf_interface names
1084 :param interface_name:
1088 if ':' in interface_name
:
1089 vnf_id
, vnf_interface
= interface_name
.split(':')
1090 vnf_sap_docker_name
= interface_name
.replace(':', '_')
1092 vnf_id
= interface_name
1093 vnf_interface
= interface_name
1094 vnf_sap_docker_name
= interface_name
1096 return vnf_id
, vnf_interface
, vnf_sap_docker_name
1098 if __name__
== '__main__':
1100 Lets allow to run the API in standalone mode.
1102 GK_STANDALONE_MODE
= True
1103 logging
.getLogger("werkzeug").setLevel(logging
.INFO
)
1104 start_rest_api("0.0.0.0", 8000)