ansible/community.general
1
0
Fork 0
mirror of https://github.com/ansible-collections/community.general.git synced 2024-09-14 20:13:21 +02:00
Code Releases Activity

Update opennebula.py

Browse source
This commit is contained in:
Tom Paine 2024-07-02 14:48:28 +01:00 • committed by GitHub
parent c1bf442048
commit 056206eb0f
No known key found for this signature in database
GPG key ID: B5690EEEBB952194
1 changed files with 1 additions and 37 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

38
plugins/inventory/opennebula.py
View file

@ -176,44 +176,8 @@ class InventoryModule(BaseInventoryPlugin, Constructable):
return vm_pool return vm_pool
def _get_host_pool_info(self):
auth = self._get_connection_info()
if not (auth.username and auth.password):
raise AnsibleError('API Credentials missing. Check OpenNebula inventory file.')
else:
one_client = pyone.OneServer(auth.url, session=auth.username + ':' + auth.password)
# get hosts (underlying hardware hosts)
try:
host_pool_info = one_client.hostpool.info()
except Exception as e:
raise AnsibleError("Something happened during XML-RPC call: {e}".format(e=to_native(e)))
return host_pool_info
def _get_vm_to_host_map(self, host_pool_info):
vm_to_host_map = {}
# Iterate over the hosts
for host in host_pool_info.HOST:
host_name = host.NAME
# Some hosts might not have VMs, so we need to check for VMS attribute
if hasattr(host, 'VMS') and hasattr(host.VMS, 'ID'):
# VMS.ID could be a single ID or a list of IDs
if isinstance(host.VMS.ID, list):
for vm_id in host.VMS.ID:
vm_to_host_map[vm_id] = host_name
else:
vm_to_host_map[host.VMS.ID] = host_name
return vm_to_host_map
def _retrieve_servers(self, label_filter=None): def _retrieve_servers(self, label_filter=None):
vm_pool = self._get_vm_pool() vm_pool = self._get_vm_pool()
host_pool_info = self._get_host_pool_info()
vm_to_host_map = self._get_vm_to_host_map(host_pool_info)
result = [] result = []
@ -236,7 +200,7 @@ class InventoryModule(BaseInventoryPlugin, Constructable):
server['name'] = vm.NAME server['name'] = vm.NAME
server['id'] = vm.ID server['id'] = vm.ID
server['host'] = vm_to_host_map.get(vm.ID, "VM ID not found") server['host'] = vm.HISTORY_RECORDS.HISTORY[-1].HOSTNAME
server['LABELS'] = labels server['LABELS'] = labels
server['v4_first_ip'] = self._get_vm_ipv4(vm) server['v4_first_ip'] = self._get_vm_ipv4(vm)
server['v6_first_ip'] = self._get_vm_ipv6(vm) server['v6_first_ip'] = self._get_vm_ipv6(vm)