Removed library, this is included directly in the default alarms role.
Change-Id: Id32445f40ca3d652fdf5e24f2acbc4be21552d3e
This commit is contained in:
Tim Kuhlman
parent
7240b74775
commit
35c43925ed
@ -1,10 +0,0 @@
|
|||||||
This directory is for Ansible modules used by this project.
|
|
||||||
|
|
||||||
The modules typically are maintained in separate git repos and added here. The preferred way to add in these repos
|
|
||||||
is with [git-subtree](https://github.com/git/git/blob/master/contrib/subtree/git-subtree.txt) as it avoids the end
|
|
||||||
user having to do anything special when downloading the code. Unfortunately this does not play well with gerrit which
|
|
||||||
is used by OpenStack. With the desire to still avoid the special clone syntax used with git submodule the files were just
|
|
||||||
imported from the upstream libraries.
|
|
||||||
|
|
||||||
- monasca comes from https://github.com/hpcloud-mon/ansible-module-monasca.git
|
|
||||||
|
|
||||||
1
library/monasca/.gitignore
vendored
1
library/monasca/.gitignore
vendored
@ -1 +0,0 @@
|
|||||||
.idea
|
|
||||||
@ -1,4 +0,0 @@
|
|||||||
# ansible-module-monasca
|
|
||||||
Ansible modules for Monasca. See the documentation for each module for more details.
|
|
||||||
|
|
||||||
For more information on [Monasca](https://wiki.openstack.org/wiki/Monasca).
|
|
||||||
@ -1,236 +0,0 @@
|
|||||||
#!/usr/bin/env python
|
|
||||||
|
|
||||||
DOCUMENTATION = '''
|
|
||||||
---
|
|
||||||
module: monasca_alarm_definition
|
|
||||||
short_description: crud operations on Monasca alarm definitions
|
|
||||||
description:
|
|
||||||
- Performs crud operations (create/update/delete) on monasca alarm definitions
|
|
||||||
- Monasca project homepage - https://wiki.openstack.org/wiki/Monasca
|
|
||||||
- When relevant the alarm_definition_id is in the output and can be used with the register action
|
|
||||||
author: Tim Kuhlman <tim@backgroundprocess.com>
|
|
||||||
requirements: [ python-monascaclient ]
|
|
||||||
options:
|
|
||||||
alarm_actions:
|
|
||||||
required: false
|
|
||||||
description:
|
|
||||||
- Array of notification method IDs that are invoked for the transition to the ALARM state.
|
|
||||||
api_version:
|
|
||||||
required: false
|
|
||||||
default: '2_0'
|
|
||||||
description:
|
|
||||||
- The monasca api version.
|
|
||||||
description:
|
|
||||||
required: false
|
|
||||||
description:
|
|
||||||
- The description associated with the alarm
|
|
||||||
expression:
|
|
||||||
required: false
|
|
||||||
description:
|
|
||||||
- The alarm expression, required for create/update operations.
|
|
||||||
keystone_password:
|
|
||||||
required: false
|
|
||||||
description:
|
|
||||||
- Keystone password to use for authentication, required unless a keystone_token is specified.
|
|
||||||
keystone_url:
|
|
||||||
required: false
|
|
||||||
description:
|
|
||||||
- Keystone url to authenticate against, required unless keystone_token isdefined.
|
|
||||||
Example http://192.168.10.5:5000/v3
|
|
||||||
keystone_token:
|
|
||||||
required: false
|
|
||||||
description:
|
|
||||||
- Keystone token to use with the monasca api. If this is specified the monasca_api_url is required but
|
|
||||||
the keystone_user and keystone_password aren't.
|
|
||||||
keystone_user:
|
|
||||||
required: false
|
|
||||||
description:
|
|
||||||
- Keystone user to log in as, required unless a keystone_token is specified.
|
|
||||||
match_by:
|
|
||||||
required: false
|
|
||||||
default: "[hostname]"
|
|
||||||
description:
|
|
||||||
- Alarm definition match by, see the monasca api documentation for more detail.
|
|
||||||
monasca_api_url:
|
|
||||||
required: false
|
|
||||||
description:
|
|
||||||
- If unset the service endpoing registered with keystone will be used.
|
|
||||||
name:
|
|
||||||
required: true
|
|
||||||
description:
|
|
||||||
- The alarm definition name
|
|
||||||
ok_actions:
|
|
||||||
required: false
|
|
||||||
description:
|
|
||||||
- Array of notification method IDs that are invoked for the transition to the OK state.
|
|
||||||
severity:
|
|
||||||
required: false
|
|
||||||
default: "LOW"
|
|
||||||
description:
|
|
||||||
- The severity set for the alarm must be LOW, MEDIUM, HIGH or CRITICAL
|
|
||||||
state:
|
|
||||||
required: false
|
|
||||||
default: "present"
|
|
||||||
choices: [ present, absent ]
|
|
||||||
description:
|
|
||||||
- Whether the account should exist. When C(absent), removes the user account.
|
|
||||||
undetermined_actions:
|
|
||||||
required: false
|
|
||||||
description:
|
|
||||||
- Array of notification method IDs that are invoked for the transition to the UNDETERMINED state.
|
|
||||||
'''
|
|
||||||
|
|
||||||
EXAMPLES = '''
|
|
||||||
- name: Host Alive Alarm
|
|
||||||
monasca_alarm_definition:
|
|
||||||
name: "Host Alive Alarm"
|
|
||||||
expression: "host_alive_status > 0"
|
|
||||||
keystone_url: "{{keystone_url}}"
|
|
||||||
keystone_user: "{{keystone_user}}"
|
|
||||||
keystone_password: "{{keystone_password}}"
|
|
||||||
tags:
|
|
||||||
- alarms
|
|
||||||
- system_alarms
|
|
||||||
register: out
|
|
||||||
- name: Create System Alarm Definitions
|
|
||||||
monasca_alarm_definition:
|
|
||||||
name: "{{item.name}}"
|
|
||||||
expression: "{{item.expression}}"
|
|
||||||
keystone_token: "{{out.keystone_token}}"
|
|
||||||
monasca_api_url: "{{out.monasca_api_url}}"
|
|
||||||
with_items:
|
|
||||||
- { name: "High CPU usage", expression: "avg(cpu.idle_perc) < 10 times 3" }
|
|
||||||
- { name: "Disk Inode Usage", expression: "disk.inode_used_perc > 90" }
|
|
||||||
'''
|
|
||||||
|
|
||||||
from ansible.module_utils.basic import *
|
|
||||||
|
|
||||||
try:
|
|
||||||
from monascaclient import client
|
|
||||||
from monascaclient import ksclient
|
|
||||||
except ImportError:
|
|
||||||
monascaclient_found = False
|
|
||||||
else:
|
|
||||||
monascaclient_found = True
|
|
||||||
|
|
||||||
|
|
||||||
# With Ansible modules including other files presents difficulties otherwise this would be in its own module
|
|
||||||
class MonascaAnsible(object):
|
|
||||||
""" A base class used to build Monasca Client based Ansible Modules
|
|
||||||
As input an ansible.module_utils.basic.AnsibleModule object is expected. It should have at least
|
|
||||||
these params defined:
|
|
||||||
- api_version
|
|
||||||
- keystone_token and monasca_api_url or keystone_url, keystone_user and keystone_password and optionally
|
|
||||||
monasca_api_url
|
|
||||||
"""
|
|
||||||
def __init__(self, module):
|
|
||||||
self.module = module
|
|
||||||
self._keystone_auth()
|
|
||||||
self.exit_data = {'keystone_token': self.token, 'monasca_api_url': self.api_url}
|
|
||||||
self.monasca = client.Client(self.module.params['api_version'], self.api_url, token=self.token)
|
|
||||||
|
|
||||||
def _exit_json(self, **kwargs):
|
|
||||||
""" Exit with supplied kwargs combined with the self.exit_data
|
|
||||||
"""
|
|
||||||
kwargs.update(self.exit_data)
|
|
||||||
self.module.exit_json(**kwargs)
|
|
||||||
|
|
||||||
def _keystone_auth(self):
|
|
||||||
""" Authenticate to Keystone and set self.token and self.api_url
|
|
||||||
"""
|
|
||||||
if self.module.params['keystone_token'] is None:
|
|
||||||
ks = ksclient.KSClient(auth_url=self.module.params['keystone_url'],
|
|
||||||
username=self.module.params['keystone_user'],
|
|
||||||
password=self.module.params['keystone_password'])
|
|
||||||
|
|
||||||
self.token = ks.token
|
|
||||||
if self.module.params['monasca_api_url'] is None:
|
|
||||||
self.api_url = ks.monasca_url
|
|
||||||
else:
|
|
||||||
self.api_url = self.module.params['monasca_api_url']
|
|
||||||
else:
|
|
||||||
if self.module.params['monasca_api_url'] is None:
|
|
||||||
self.module.fail_json(msg='Error: When specifying keystone_token, monasca_api_url is required')
|
|
||||||
self.token = self.module.params['keystone_token']
|
|
||||||
self.api_url = self.module.params['monasca_api_url']
|
|
||||||
|
|
||||||
|
|
||||||
class MonascaDefinition(MonascaAnsible):
|
|
||||||
def run(self):
|
|
||||||
name = self.module.params['name']
|
|
||||||
expression = self.module.params['expression']
|
|
||||||
|
|
||||||
# Find existing definitions
|
|
||||||
definitions = {definition['name']: definition for definition in self.monasca.alarm_definitions.list()}
|
|
||||||
|
|
||||||
if self.module.params['state'] == 'absent':
|
|
||||||
if name not in definitions.keys():
|
|
||||||
self._exit_json(changed=False)
|
|
||||||
|
|
||||||
if self.module.check_mode:
|
|
||||||
self._exit_json(changed=True)
|
|
||||||
resp = self.monasca.alarm_definitions.delete(alarm_id=definitions[name]['id'])
|
|
||||||
if resp.status_code == 204:
|
|
||||||
self._exit_json(changed=True)
|
|
||||||
else:
|
|
||||||
self.module.fail_json(msg=str(resp.status_code) + resp.text)
|
|
||||||
else: # Only other option is state=present
|
|
||||||
def_kwargs = {"name": name, "description": self.module.params['description'], "expression": expression,
|
|
||||||
"match_by": self.module.params['match_by'], "severity": self.module.params['severity'],
|
|
||||||
"alarm_actions": self.module.params['alarm_actions'],
|
|
||||||
"ok_actions": self.module.params['ok_actions'],
|
|
||||||
"undetermined_actions": self.module.params['undetermined_actions']}
|
|
||||||
|
|
||||||
if name in definitions.keys():
|
|
||||||
if definitions[name]['expression'] == expression and \
|
|
||||||
definitions[name]['alarm_actions'] == self.module.params['alarm_actions'] and \
|
|
||||||
definitions[name]['ok_actions'] == self.module.params['ok_actions'] and \
|
|
||||||
definitions[name]['undetermined_actions'] == self.module.params['undetermined_actions']:
|
|
||||||
self._exit_json(changed=False, alarm_definition_id=definitions[name]['id'])
|
|
||||||
def_kwargs['alarm_id'] = definitions[name]['id']
|
|
||||||
|
|
||||||
if self.module.check_mode:
|
|
||||||
self._exit_json(changed=True, alarm_definition_id=definitions[name]['id'])
|
|
||||||
body = self.monasca.alarm_definitions.patch(**def_kwargs)
|
|
||||||
else:
|
|
||||||
if self.module.check_mode:
|
|
||||||
self._exit_json(changed=True)
|
|
||||||
body = self.monasca.alarm_definitions.create(**def_kwargs)
|
|
||||||
|
|
||||||
if 'id' in body:
|
|
||||||
self._exit_json(changed=True, alarm_definition_id=body['id'])
|
|
||||||
else:
|
|
||||||
self.module.fail_json(msg=body)
|
|
||||||
|
|
||||||
|
|
||||||
def main():
|
|
||||||
module = AnsibleModule(
|
|
||||||
argument_spec=dict(
|
|
||||||
alarm_actions=dict(required=False, default=[], type='list'),
|
|
||||||
api_version=dict(required=False, default='2_0', type='str'),
|
|
||||||
description=dict(required=False, type='str'),
|
|
||||||
expression=dict(required=False, type='str'),
|
|
||||||
keystone_password=dict(required=False, type='str'),
|
|
||||||
keystone_token=dict(required=False, type='str'),
|
|
||||||
keystone_url=dict(required=False, type='str'),
|
|
||||||
keystone_user=dict(required=False, type='str'),
|
|
||||||
match_by=dict(default=['hostname'], type='list'),
|
|
||||||
monasca_api_url=dict(required=False, type='str'),
|
|
||||||
name=dict(required=True, type='str'),
|
|
||||||
ok_actions=dict(required=False, default=[], type='list'),
|
|
||||||
severity=dict(default='LOW', type='str'),
|
|
||||||
state=dict(default='present', choices=['present', 'absent'], type='str'),
|
|
||||||
undetermined_actions=dict(required=False, default=[], type='list')
|
|
||||||
),
|
|
||||||
supports_check_mode=True
|
|
||||||
)
|
|
||||||
|
|
||||||
if not monascaclient_found:
|
|
||||||
module.fail_json(msg="python-monascaclient >= 1.0.9 is required")
|
|
||||||
|
|
||||||
definition = MonascaDefinition(module)
|
|
||||||
definition.run()
|
|
||||||
|
|
||||||
|
|
||||||
if __name__ == "__main__":
|
|
||||||
main()
|
|
||||||
@ -1,193 +0,0 @@
|
|||||||
#!/usr/bin/env python
|
|
||||||
|
|
||||||
DOCUMENTATION = '''
|
|
||||||
---
|
|
||||||
module: monasca_notification_method
|
|
||||||
short_description: crud operations for Monasca notifications methods
|
|
||||||
description:
|
|
||||||
- Performs crud operations (create/update/delete) on monasca notification methods
|
|
||||||
- Monasca project homepage - https://wiki.openstack.org/wiki/Monasca
|
|
||||||
- When relevant the notification_id is in the output and can be used with the register action
|
|
||||||
author: Tim Kuhlman <tim@backgroundprocess.com>
|
|
||||||
requirements: [ python-monascaclient ]
|
|
||||||
options:
|
|
||||||
address:
|
|
||||||
required: true
|
|
||||||
description:
|
|
||||||
- The notification method address corresponding to the type.
|
|
||||||
api_version:
|
|
||||||
required: false
|
|
||||||
default: '2_0'
|
|
||||||
description:
|
|
||||||
- The monasca api version.
|
|
||||||
keystone_password:
|
|
||||||
required: false
|
|
||||||
description:
|
|
||||||
- Keystone password to use for authentication, required unless a keystone_token is specified.
|
|
||||||
keystone_url:
|
|
||||||
required: false
|
|
||||||
description:
|
|
||||||
- Keystone url to authenticate against, required unless keystone_token isdefined.
|
|
||||||
Example http://192.168.10.5:5000/v3
|
|
||||||
keystone_token:
|
|
||||||
required: false
|
|
||||||
description:
|
|
||||||
- Keystone token to use with the monasca api. If this is specified the monasca_api_url is required but
|
|
||||||
the keystone_user and keystone_password aren't.
|
|
||||||
keystone_user:
|
|
||||||
required: false
|
|
||||||
description:
|
|
||||||
- Keystone user to log in as, required unless a keystone_token is specified.
|
|
||||||
monasca_api_url:
|
|
||||||
required: false
|
|
||||||
description:
|
|
||||||
- If unset the service endpoing registered with keystone will be used.
|
|
||||||
name:
|
|
||||||
required: true
|
|
||||||
description:
|
|
||||||
- The notification method name
|
|
||||||
state:
|
|
||||||
required: false
|
|
||||||
default: "present"
|
|
||||||
choices: [ present, absent ]
|
|
||||||
description:
|
|
||||||
- Whether the account should exist. When C(absent), removes the user account.
|
|
||||||
type:
|
|
||||||
required: true
|
|
||||||
description:
|
|
||||||
- The notification type. This must be one of the types supported by the Monasca API.
|
|
||||||
'''
|
|
||||||
|
|
||||||
EXAMPLES = '''
|
|
||||||
- name: Setup root email notification method
|
|
||||||
monasca_notification_method:
|
|
||||||
name: "Email Root"
|
|
||||||
type: 'EMAIL'
|
|
||||||
address: 'root@localhost'
|
|
||||||
keystone_url: "{{keystone_url}}"
|
|
||||||
keystone_user: "{{keystone_user}}"
|
|
||||||
keystone_password: "{{keystone_password}}"
|
|
||||||
register: out
|
|
||||||
- name: Create System Alarm Definitions
|
|
||||||
monasca_alarm_definition:
|
|
||||||
name: "Host Alive Alarm"
|
|
||||||
expression: "host_alive_status > 0"
|
|
||||||
keystone_token: "{{out.keystone_token}}"
|
|
||||||
monasca_api_url: "{{out.monasca_api_url}}"
|
|
||||||
alarm_actions:
|
|
||||||
- "{{out.notification_method_id}}"
|
|
||||||
ok_actions:
|
|
||||||
- "{{out.notification_method_id}}"
|
|
||||||
undetermined_actions:
|
|
||||||
- "{{out.notification_method_id}}"
|
|
||||||
'''
|
|
||||||
|
|
||||||
from ansible.module_utils.basic import *
|
|
||||||
|
|
||||||
try:
|
|
||||||
from monascaclient import client
|
|
||||||
from monascaclient import ksclient
|
|
||||||
except ImportError:
|
|
||||||
monascaclient_found = False
|
|
||||||
else:
|
|
||||||
monascaclient_found = True
|
|
||||||
|
|
||||||
|
|
||||||
# With Ansible modules including other files presents difficulties otherwise this would be in its own module
|
|
||||||
class MonascaAnsible(object):
|
|
||||||
""" A base class used to build Monasca Client based Ansible Modules
|
|
||||||
As input an ansible.module_utils.basic.AnsibleModule object is expected. It should have at least
|
|
||||||
these params defined:
|
|
||||||
- api_version
|
|
||||||
- keystone_token and monasca_api_url or keystone_url, keystone_user and keystone_password and optionally
|
|
||||||
monasca_api_url
|
|
||||||
"""
|
|
||||||
def __init__(self, module):
|
|
||||||
self.module = module
|
|
||||||
self._keystone_auth()
|
|
||||||
self.exit_data = {'keystone_token': self.token, 'monasca_api_url': self.api_url}
|
|
||||||
self.monasca = client.Client(self.module.params['api_version'], self.api_url, token=self.token)
|
|
||||||
|
|
||||||
def _exit_json(self, **kwargs):
|
|
||||||
""" Exit with supplied kwargs combined with the self.exit_data
|
|
||||||
"""
|
|
||||||
kwargs.update(self.exit_data)
|
|
||||||
self.module.exit_json(**kwargs)
|
|
||||||
|
|
||||||
def _keystone_auth(self):
|
|
||||||
""" Authenticate to Keystone and set self.token and self.api_url
|
|
||||||
"""
|
|
||||||
if self.module.params['keystone_token'] is None:
|
|
||||||
ks = ksclient.KSClient(auth_url=self.module.params['keystone_url'],
|
|
||||||
username=self.module.params['keystone_user'],
|
|
||||||
password=self.module.params['keystone_password'])
|
|
||||||
|
|
||||||
self.token = ks.token
|
|
||||||
if self.module.params['monasca_api_url'] is None:
|
|
||||||
self.api_url = ks.monasca_url
|
|
||||||
else:
|
|
||||||
self.api_url = self.module.params['monasca_api_url']
|
|
||||||
else:
|
|
||||||
if self.module.params['monasca_api_url'] is None:
|
|
||||||
self.module.fail_json(msg='Error: When specifying keystone_token, monasca_api_url is required')
|
|
||||||
self.token = self.module.params['keystone_token']
|
|
||||||
self.api_url = self.module.params['monasca_api_url']
|
|
||||||
|
|
||||||
|
|
||||||
class MonascaNotification(MonascaAnsible):
|
|
||||||
def run(self):
|
|
||||||
name = self.module.params['name']
|
|
||||||
type = self.module.params['type']
|
|
||||||
address = self.module.params['address']
|
|
||||||
|
|
||||||
notifications = {notif['name']:notif for notif in self.monasca.notifications.list()}
|
|
||||||
if name in notifications.keys():
|
|
||||||
notification = notifications[name]
|
|
||||||
else:
|
|
||||||
notification = None
|
|
||||||
|
|
||||||
if self.module.params['state'] == 'absent':
|
|
||||||
if notification is None:
|
|
||||||
self._exit_json(changed=False)
|
|
||||||
else:
|
|
||||||
self.monasca.notifications.delete(notification_id=notification['id'])
|
|
||||||
self._exit_json(changed=True)
|
|
||||||
else: # Only other option is present
|
|
||||||
if notification is None:
|
|
||||||
body = self.monasca.notifications.create(name=name, type=type, address=address)
|
|
||||||
self._exit_json(changed=True, notification_method_id=body['id'])
|
|
||||||
else:
|
|
||||||
if notification['type'] == type and notification['address'] == address:
|
|
||||||
self._exit_json(changed=False, notification_method_id=notification['id'])
|
|
||||||
else:
|
|
||||||
self.monasca.notifications.update(notification_id=notification['id'],
|
|
||||||
name=name, type=type, address=address)
|
|
||||||
self._exit_json(changed=True, notification_method_id=notification['id'])
|
|
||||||
|
|
||||||
|
|
||||||
def main():
|
|
||||||
module = AnsibleModule(
|
|
||||||
argument_spec=dict(
|
|
||||||
address=dict(required=True, type='str'),
|
|
||||||
api_version=dict(required=False, default='2_0', type='str'),
|
|
||||||
keystone_password=dict(required=False, type='str'),
|
|
||||||
keystone_token=dict(required=False, type='str'),
|
|
||||||
keystone_url=dict(required=False, type='str'),
|
|
||||||
keystone_user=dict(required=False, type='str'),
|
|
||||||
monasca_api_url=dict(required=False, type='str'),
|
|
||||||
name=dict(required=True, type='str'),
|
|
||||||
state=dict(default='present', choices=['present', 'absent'], type='str'),
|
|
||||||
type=dict(required=True, type='str')
|
|
||||||
),
|
|
||||||
supports_check_mode=True
|
|
||||||
)
|
|
||||||
|
|
||||||
if not monascaclient_found:
|
|
||||||
module.fail_json(msg="python-monascaclient >= 1.0.9 is required")
|
|
||||||
|
|
||||||
notification = MonascaNotification(module)
|
|
||||||
notification.run()
|
|
||||||
|
|
||||||
|
|
||||||
if __name__ == "__main__":
|
|
||||||
main()
|
|
||||||
Loading…
x
Reference in New Issue
Block a user