Skip to content

updating to use keystone v3 api #3

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Open
logan2211 wants to merge 1 commit into
base: master
Choose a base branch
from
Open

updating to use keystone v3 api #3

Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
39 changes: 24 additions & 15 deletions server/externalscripts/openstack-discovery
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -6,21 +6,22 @@ from sys import argv
from sys import stderr
import json
from datetime import datetime
import re
from urlparse import urlparse


try:
from keystoneclient.v2_0 import client as keystone_client
from keystoneclient.auth.identity import v2
from novaclient import client
from keystoneclient.v3 import client as keystone_client
from keystoneauth1 import loading
from keystoneauth1 import session
from novaclient import client as nova_client
except ImportError:
print 'ZBX_NOTSUPPORTED\x00 Failed to import openstack python modules'
exit(1)

def get_host_port(url):
m = re.match('htt.?://(.*):(\d+)',url)
if m:
return (m.group(1),m.group(2))
parsed = urlparse(url)
if parsed:
return (parsed.hostname, parsed.port)

def print_json(data):
print json.dumps({'data':data},sort_keys=True,indent=7,separators=(',',':'))
Expand All @@ -30,15 +31,26 @@ def discover_endpoints(auth_url, tenant_name, username, password):

services = []
for e in conn.endpoints.list():
host = get_host_port(e.publicurl)
if e.interface != 'public':
continue
host = get_host_port(e.url)
if e.enabled:
service = conn.services.get(e.service_id)
services.append({'{#OS_SERVICENAME}':service.name, '{#OS_SERVICEURL}':e.publicurl, '{#OS_SERVICEHOST}':host[0], '{#OS_SERVICEPORT}':host[1] })
services.append({'{#OS_SERVICENAME}':service.name, '{#OS_SERVICEURL}':e.url, '{#OS_SERVICEHOST}':host[0], '{#OS_SERVICEPORT}':host[1] })

print_json(services)

def discover_hypervisors(auth_url, tenant_name, username, password):
conn = nova = client.Client(2, username, password, tenant_name, auth_url)
loader = loading.get_plugin_loader('password')
print loader.get_options()
auth = loader.load_from_options(auth_url=auth_url,
username=username,
password=password,
project_name=tenant_name,
user_domain_name='default',
project_domain_name='default')
sess = session.Session(auth=auth)
conn = nova_client.Client(2, session=sess)

hypervisors = []
for h in conn.hypervisors.list(detailed=True):
Expand All @@ -49,12 +61,12 @@ def discover_hypervisors(auth_url, tenant_name, username, password):

if __name__ == '__main__':

if (len(argv) != 6):
if (len(argv) != 6):
print """Usage: %s TYPE AUTH_URL TENANT USERNAME PASSWORD
where

TYPE - one of the following: endpoints hypervisors
AUTH_URL - URL to keystone
AUTH_URL - URL to keystone
TENANT - tenant name
USERNAME - user name
PASSWORD - password for user
Expand All @@ -70,6 +82,3 @@ if __name__ == '__main__':
else:
print 'ZBX_NOTSUPPORTED\x00 Unknown type: %s' % TYPE
exit(1)