#!/usr/bin/env python
#
# jose.lausuch@ericsson.com
# valentin.boucher@orange.com
# All rights reserved. This program and the accompanying materials
# are made available under the terms of the Apache License, Version 2.0
# which accompanies this distribution, and is available at
# http://www.apache.org/licenses/LICENSE-2.0
#
import os
import os.path
import urllib2
import subprocess
import sys
import requests
import json
import shutil
from git import Repo
# ############ CREDENTIALS OPENSTACK #############
def check_credentials():
"""
Check if the OpenStack credentials (openrc) are sourced
"""
env_vars = ['OS_AUTH_URL', 'OS_USERNAME', 'OS_PASSWORD', 'OS_TENANT_NAME']
return all(map(lambda v: v in os.environ and os.environ[v], env_vars))
def get_credentials(service):
"""Returns a creds dictionary filled with the following keys:
* username
* password/api_key (depending on the service)
* tenant_name/project_id (depending on the service)
* auth_url
:param service: a string indicating the name of the service
requesting the credentials.
"""
creds = {}
# Unfortunately, each of the OpenStack client will request slightly
# different entries in their credentials dict.
if service.lower() in ("nova", "cinder"):
password = "api_key"
tenant = "project_id"
else:
password = "password"
tenant = "tenant_name"
# The most common way to pass these info to the script is to do it through
# environment variables.
creds.update({
"username": os.environ.get('OS_USERNAME', "admin"),
password: os.environ.get("OS_PASSWORD", 'admin'),
"auth_url": os.environ.get("OS_AUTH_URL",
"http://192.168.20.71:5000/v2.0"),
tenant: os.environ.get("OS_TENANT_NAME", "admin"),
})
return creds
# ################ NOVA #################
def get_instances(nova_client):
try:
instances = nova_client.servers.list(search_opts={'all_tenants': 1})
return instances
except:
return None
def get_instance_status(nova_client, instance):
try:
instance = nova_client.servers.get(instance.id)
return instance.status
except:
return None
def get_instance_by_name(nova_client, instance_name):
try:
instance = nova_client.servers.find(name=instance_name)
return instance
except:
return None
def get_flavor_id(nova_client, flavor_name):
flavors = nova_client.flavors.list(detailed=True)
id = ''
for f in flavors:
if f.name == flavor_name:
id = f.id
break
return id
def get_flavor_id_by_ram_range(nova_client, min_ram, max_ram):
flavors = nova_client.flavors.list(detailed=True)
id = ''
for f in flavors:
if min_ram <= f.ram and f.ram <= max_ram:
id = f.id
break
return id
def delete_instance(nova_client, instance_id):
try:
nova_client.servers.force_delete(instance_id)
return True
except:
print "Error:", sys.exc_info()[0]
return False
def get_floating_ips(nova_client):
try:
floating_ips = nova_client.floating_ips.list()
return floating_ips
except:
return None
def delete_floating_ip(nova_client, floatingip_id):
try:
nova_client.floating_ips.delete(floatingip_id)
return True
except:
print "Error:", sys.exc_info()[0]
return None
# ################ NEUTRON #################
def create_neutron_net(neutron_client, name):
json_body = {'network': {'name': name,
'admin_state_up': True}}
try:
network = neutron_client.create_network(body=json_body)
network_dict = network['network']
return network_dict['id']
except:
print "Error:", sys.exc_info()[0]
return False
def update_neutron_net(neutron_client, network_id, shared=False):
json_body = {'network': {'shared': shared}}
try:
neutron_client.update_network(network_id, body=json_body)
return True
except:
print "Error:", sys.exc_info()[0]
return False
def delete_neutron_net(neutron_client, network_id):
try:
neutron_client.delete_network(network_id)
return True
except:
print "Error:", sys.exc_info()[0]
return False
def c