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

cloudstack: inventory: Added feature list by tag (#31319)

Browse source
This commit is contained in:
Danilo Riecken P. de Morais 2018-01-14 20:42:31 +01:00 committed by René Moser
parent 698d5a524c
commit 5540e2f8a9
1 changed files with 11 additions and 6 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

17
contrib/inventory/cloudstack.py
View file

@ -95,6 +95,7 @@ class CloudStackInventory(object):
parser = argparse.ArgumentParser() parser = argparse.ArgumentParser()
parser.add_argument('--host') parser.add_argument('--host')
parser.add_argument('--list', action='store_true') parser.add_argument('--list', action='store_true')
parser.add_argument('--tag', help="Filter machines by a tag. Should be in the form key=value.")
parser.add_argument('--project') parser.add_argument('--project')
parser.add_argument('--domain') parser.add_argument('--domain')
@ -117,10 +118,14 @@ class CloudStackInventory(object):
print(json.dumps(data, indent=2)) print(json.dumps(data, indent=2))
elif options.list: elif options.list:
data = self.get_list(project_id, domain_id) tags = dict()
if options.tag:
tags['tags[0].key'], tags['tags[0].value'] = options.tag.split('=')
data = self.get_list(project_id, domain_id, **tags)
print(json.dumps(data, indent=2)) print(json.dumps(data, indent=2))
else: else:
print("usage: --list | --host <hostname> [--project <project>] [--domain <domain_path>]", file=sys.stderr) print("usage: --list [--tag <tag>] | --host <hostname> [--project <project>] [--domain <domain_path>]",
file=sys.stderr)
sys.exit(1) sys.exit(1)
def get_domain_id(self, domain): def get_domain_id(self, domain):
@ -141,8 +146,8 @@ class CloudStackInventory(object):
print("Error: Project %s not found." % project, file=sys.stderr) print("Error: Project %s not found." % project, file=sys.stderr)
sys.exit(1) sys.exit(1)
def get_host(self, name, project_id=None, domain_id=None): def get_host(self, name, project_id=None, domain_id=None, **kwargs):
hosts = self.cs.listVirtualMachines(projectid=project_id, domainid=domain_id) hosts = self.cs.listVirtualMachines(projectid=project_id, domainid=domain_id, **kwargs)
data = {} data = {}
if not hosts: if not hosts:
return data return data
@ -178,7 +183,7 @@ class CloudStackInventory(object):
break break
return data return data
def get_list(self, project_id=None, domain_id=None): def get_list(self, project_id=None, domain_id=None, **kwargs):
data = { data = {
'all': { 'all': {
'hosts': [], 'hosts': [],
@ -197,7 +202,7 @@ class CloudStackInventory(object):
'hosts': [] 'hosts': []
} }
hosts = self.cs.listVirtualMachines(projectid=project_id, domainid=domain_id) hosts = self.cs.listVirtualMachines(projectid=project_id, domainid=domain_id, **kwargs)
if not hosts: if not hosts:
return data return data
for host in hosts['virtualmachine']: for host in hosts['virtualmachine']: