| 26 |
26 |
DEFAULT_SYSTEM_IMAGES_UUID = [
|
| 27 |
27 |
"25ecced9-bf53-4145-91ee-cf47377e9fb2", # production (okeanos.grnet.gr)
|
| 28 |
28 |
"04cbe33f-29b7-4ef1-94fb-015929e5fc06", # testing (okeanos.io)
|
| 29 |
|
]
|
|
29 |
]
|
| 30 |
30 |
|
| 31 |
31 |
|
| 32 |
32 |
def _run(cmd, verbose):
|
| ... | ... | |
| 190 |
190 |
token = config.get_cloud(self.kamaki_cloud, "token")
|
| 191 |
191 |
#self.logger.debug("Token is %s" % _green(token))
|
| 192 |
192 |
|
| 193 |
|
astakos_client = AstakosClient(auth_url, token)
|
|
193 |
self.astakos_client = AstakosClient(auth_url, token)
|
| 194 |
194 |
|
| 195 |
195 |
cyclades_url = \
|
| 196 |
|
astakos_client.get_service_endpoints('compute')['publicURL']
|
|
196 |
self.astakos_client.get_service_endpoints('compute')['publicURL']
|
| 197 |
197 |
self.logger.debug("Cyclades API url is %s" % _green(cyclades_url))
|
| 198 |
198 |
self.cyclades_client = CycladesClient(cyclades_url, token)
|
| 199 |
199 |
self.cyclades_client.CONNECTION_RETRY_LIMIT = 2
|
| 200 |
200 |
|
| 201 |
201 |
image_url = \
|
| 202 |
|
astakos_client.get_service_endpoints('image')['publicURL']
|
|
202 |
self.astakos_client.get_service_endpoints('image')['publicURL']
|
| 203 |
203 |
self.logger.debug("Images API url is %s" % _green(image_url))
|
| 204 |
204 |
self.image_client = ImageClient(cyclades_url, token)
|
| 205 |
205 |
self.image_client.CONNECTION_RETRY_LIMIT = 2
|
| 206 |
206 |
|
| 207 |
207 |
compute_url = \
|
| 208 |
|
astakos_client.get_service_endpoints('compute')['publicURL']
|
|
208 |
self.astakos_client.get_service_endpoints('compute')['publicURL']
|
| 209 |
209 |
self.logger.debug("Compute API url is %s" % _green(compute_url))
|
| 210 |
210 |
self.compute_client = ComputeClient(compute_url, token)
|
| 211 |
211 |
self.compute_client.CONNECTION_RETRY_LIMIT = 2
|
| ... | ... | |
| 332 |
332 |
|
| 333 |
333 |
list_flavors = self.compute_client.list_flavors()
|
| 334 |
334 |
for flv in flavors:
|
| 335 |
|
flv_type, flv_value = parse_typed_option(option="flavor", value=flv)
|
|
335 |
flv_type, flv_value = parse_typed_option(option="flavor",
|
|
336 |
value=flv)
|
| 336 |
337 |
if flv_type == "name":
|
| 337 |
338 |
# Filter flavors by name
|
| 338 |
339 |
self.logger.debug(
|
| 339 |
340 |
"Trying to find a flavor with name \"%s\"" % flv_value)
|
| 340 |
341 |
list_flvs = \
|
| 341 |
342 |
[f for f in list_flavors
|
| 342 |
|
if re.search(flv_value, f['name'], flags=re.I) is not None]
|
|
343 |
if re.search(flv_value, f['name'], flags=re.I)
|
|
344 |
is not None]
|
| 343 |
345 |
elif flv_type == "id":
|
| 344 |
346 |
# Filter flavors by id
|
| 345 |
347 |
self.logger.debug(
|
| ... | ... | |
| 372 |
374 |
# If we have an image from command line, add it to our list
|
| 373 |
375 |
images.insert(0, image)
|
| 374 |
376 |
|
|
377 |
auth = self.astakos_client.authenticate()
|
|
378 |
user_uuid = auth["access"]["token"]["tenant"]["id"]
|
| 375 |
379 |
list_images = self.image_client.list_public(detail=True)['images']
|
| 376 |
380 |
for img in images:
|
| 377 |
381 |
img_type, img_value = parse_typed_option(option="image", value=img)
|
| ... | ... | |
| 379 |
383 |
# Filter images by name
|
| 380 |
384 |
self.logger.debug(
|
| 381 |
385 |
"Trying to find an image with name \"%s\"" % img_value)
|
|
386 |
accepted_uuids = DEFAULT_SYSTEM_IMAGES_UUID + [user_uuid]
|
| 382 |
387 |
list_imgs = \
|
| 383 |
|
[i for i in list_images
|
| 384 |
|
if i['user_id'] in DEFAULT_SYSTEM_IMAGES_UUID and
|
| 385 |
|
re.search(img_value, i['name'], flags=re.I) is not None]
|
|
388 |
[i for i in list_images if i['user_id'] in accepted_uuids
|
|
389 |
and
|
|
390 |
re.search(img_value, i['name'], flags=re.I) is not None]
|
| 386 |
391 |
elif img_type == "id":
|
| 387 |
392 |
# Filter images by id
|
| 388 |
393 |
self.logger.debug(
|
| ... | ... | |
| 421 |
426 |
self.write_temp_config('server_port', server_port)
|
| 422 |
427 |
self.logger.debug("Server's ssh port is %s" % _green(server_port))
|
| 423 |
428 |
self.logger.debug("Access server using \"ssh -X -p %s %s@%s\"" %
|
| 424 |
|
(server_port, server['metadata']['users'], server_ip))
|
|
429 |
(server_port, server['metadata']['users'],
|
|
430 |
server_ip))
|
| 425 |
431 |
|
| 426 |
432 |
@_check_fabric
|
| 427 |
433 |
def _copy_ssh_keys(self, ssh_keys):
|
| ... | ... | |
| 432 |
438 |
|
| 433 |
439 |
if ssh_keys != "":
|
| 434 |
440 |
ssh_keys = os.path.expanduser(ssh_keys)
|
| 435 |
|
self.logger.debug("Will use %s authentication keys file" % ssh_keys)
|
|
441 |
self.logger.debug("Will use %s authentication keys file" %
|
|
442 |
ssh_keys)
|
| 436 |
443 |
keyfile = '/tmp/%s.pub' % fabric.env.user
|
| 437 |
444 |
_run('mkdir -p ~/.ssh && chmod 700 ~/.ssh', False)
|
| 438 |
445 |
if ssh_keys.startswith("http://") or \
|