On 04/27/2012 04:06 PM, Juan Hernandez wrote:
On 04/26/2012 05:49 PM, Alex Jia wrote:
I built ovirt-engine-sdk rpm based on git repo 
'http://gerrit.ovirt.org/p/ovirt-engine-sdk.git',
then the ovirt-engine-sdk works well for me, I can get resource information 
from Ovirt/RHEVM(3.0)
on the rhel6.2.

The only question is I can't get latest resource status when I changed VM from 
'suspended' to 'up'
status, the api.vms.get(vm_name).status.state is always 'suspended' status, I 
can get a correct
VM status unless I reconnect Ovirt/RHEVM, it's not convenient for users, I 
remember there are reload
and wait_for_status method in old python binding API of RHEV(python-rhev), the 
wait_for_status method
will reload resource then get current resource status, however, I haven't found 
similar method in
ovirt-engine-sdk.
Are you sure you are calling api.vms.get(vm_name) each time? Or are you
doing something like this:

vm = api.vms.get(vm_name)
while vm.status.state == "suspended":
     sleep(10)
Yeah, I put 'api.vms.get(vm_name)' in a loop body like above codes.
If you are doing that the vm information is retrieved only once, not
each time. If this is the case try something like this:

while api.vms.get(VM_NAME).status.state == "suspended":
     sleep(1)

Can you share that snippet of code so that I can try to reproduce it?
Okay, I will list my snippet of code in here, you may replace 'logging' with 'print' then remove
useless '()' if need. thanks.


<snip>
import time, logging
from ovirtsdk.api import API
from ovirtsdk.xml import params

class RHEV(object):
    """
    RHEV class
    """

    def __init__(self, url, username, password):
        try:
            self.api = API(url, username, password)
        except Exception as e:
            logging.error('could not connect: %s\n' % str(e))
        else:
            logging.info('success: RHEV manager could be reached OK\n')

    def vm_start(self, vm_name):
        try:
            vm = self.api.vms.get(vm_name)
            if vm.status.state != 'up':
                logging.info('Starting VM')
                vm.start()
                logging.info('Waiting for VM to reach Up status')
                while vm.status.state != 'up':
                    time.sleep(1)
            else:
                logging.debug('VM already up')
        except Exception as e:
            logging.error('Failed to start VM:\n%s' % str(e))

    def vm_suspend(self, vm_name):
        vm = self.api.vms.get(vm_name)
        while vm.status.state != 'suspended':
            try:
                logging.info('Suspend VM')
                vm.suspend()
                logging.info('Waiting for VM to reach suspended status')
                while vm.status.state != 'suspended':
                    time.sleep(1)

            except Exception as e:
                if e.reason == 'Bad Request' \
                    and 'asynchronous running tasks' in e.detail:
logging.warning('VM has asynchronous running tasks, trying again')
                    time.sleep(1)
                else:
                    logging.error('Failed to suspend VM:\n%s' % str(e))
                    break

    def vm_resume(self, vm_name):
        try:
            vm = self.api.vms.get(vm_name)
            if vm.status.state != 'up':
                logging.info('Resume VM')
                vm.start()
                logging.info('Waiting for VM to resume')
                while vm.status.state != 'up':
                    time.sleep(1)
            else:
                logging.debug('VM already up')
        except Exception as e:
            logging.error('Failed to resume VM:\n%s' % str(e))

</snip>

_______________________________________________
Users mailing list
Users@ovirt.org
http://lists.ovirt.org/mailman/listinfo/users

Reply via email to