Add check_vm_templates management command
This commit is contained in:
parent
585e9cf146
commit
890a83cfa6
1 changed files with 62 additions and 0 deletions
62
datacenterlight/management/commands/check_vm_templates.py
Normal file
62
datacenterlight/management/commands/check_vm_templates.py
Normal file
|
@ -0,0 +1,62 @@
|
|||
from django.core.management.base import BaseCommand
|
||||
from opennebula_api.models import OpenNebulaManager
|
||||
from datacenterlight.models import VMTemplate
|
||||
from membership.models import CustomUser
|
||||
|
||||
from django.conf import settings
|
||||
from time import sleep
|
||||
import datetime
|
||||
import json
|
||||
import logging
|
||||
import os
|
||||
|
||||
logger = logging.getLogger(__name__)
|
||||
|
||||
|
||||
class Command(BaseCommand):
|
||||
help = '''Checks all VM templates to find if they can be instantiated'''
|
||||
|
||||
def add_arguments(self, parser):
|
||||
parser.add_argument('user_email', type=str)
|
||||
|
||||
def handle(self, *args, **options):
|
||||
result_dict = {}
|
||||
user_email = options['user_email'] if 'user_email' in options else ""
|
||||
|
||||
if user_email:
|
||||
cu = CustomUser.objects.get(email=user_email)
|
||||
specs = {'cpu': 1, 'memory': 1, 'disk_size': 10}
|
||||
manager = OpenNebulaManager(email=user_email, password=cu.password)
|
||||
pub_keys = [settings.TEST_MANAGE_SSH_KEY_PUBKEY]
|
||||
if not os.path.exists("outputs"):
|
||||
os.mkdir("outputs")
|
||||
for vm_template in VMTemplate.objects.all():
|
||||
vm_name = 'test-%s' % vm_template.name
|
||||
vm_id = manager.create_vm(
|
||||
template_id=vm_template.opennebula_vm_template_id,
|
||||
specs=specs,
|
||||
ssh_key='\n'.join(pub_keys),
|
||||
vm_name=vm_name
|
||||
)
|
||||
if vm_id > 0:
|
||||
result_dict[vm_name] = "%s OK, created VM %s" % (
|
||||
'%s %s' % (vm_template.opennebula_vm_template_id,
|
||||
vm_template.name),
|
||||
vm_id
|
||||
)
|
||||
self.stdout.write(self.style.SUCCESS(result_dict[vm_name]))
|
||||
manager.delete_vm(vm_id)
|
||||
else:
|
||||
result_dict[vm_name] = '''Error creating VM %s, template_id
|
||||
%s ''' % (vm_name, vm_template.opennebula_vm_template_id)
|
||||
self.stdout.write(self.style.ERROR(result_dict[vm_name]))
|
||||
sleep(1)
|
||||
date_str = datetime.datetime.strftime(
|
||||
datetime.datetime.now(), '%Y%m%d%H%M%S'
|
||||
)
|
||||
with open("output/check_vm_templates_%s.txt" % date_str, 'w',
|
||||
encoding='utf-8') as f:
|
||||
f.write(json.dumps(result_dict))
|
||||
else:
|
||||
self.stdout.write(self.style.ERROR("user_email not supplied"))
|
||||
self.stdout.write(self.style.SUCCESS("Done"))
|
Loading…
Reference in a new issue