[Python-modules-commits] [python-zenoss] 01/04: import python-zenoss_0.6.2.orig.tar.gz
Sandro Tosi
morph at moszumanska.debian.org
Thu Jul 14 07:46:09 UTC 2016
This is an automated email from the git hooks/post-receive script.
morph pushed a commit to branch master
in repository python-zenoss.
commit a0fc3a62014ff7ea37d656f607491082a3308ce7
Author: Sandro Tosi <morph at debian.org>
Date: Thu Jul 14 03:43:02 2016 -0400
import python-zenoss_0.6.2.orig.tar.gz
---
PKG-INFO | 11 ++
setup.cfg | 8 +
setup.py | 15 ++
zenoss.egg-info/PKG-INFO | 11 ++
zenoss.egg-info/SOURCES.txt | 8 +
zenoss.egg-info/dependency_links.txt | 1 +
zenoss.egg-info/pbr.json | 1 +
zenoss.egg-info/top_level.txt | 1 +
zenoss.py | 287 +++++++++++++++++++++++++++++++++++
9 files changed, 343 insertions(+)
diff --git a/PKG-INFO b/PKG-INFO
new file mode 100644
index 0000000..289862f
--- /dev/null
+++ b/PKG-INFO
@@ -0,0 +1,11 @@
+Metadata-Version: 1.0
+Name: zenoss
+Version: 0.6.2
+Summary: Module to work with the Zenoss JSON API.
+Home-page: https://github.com/iamseth/python-zenoss
+Author: Seth Miller
+Author-email: seth at sethmiller.me
+License: UNKNOWN
+Description: UNKNOWN
+Keywords: zenoss,api,json,rest
+Platform: UNKNOWN
diff --git a/setup.cfg b/setup.cfg
new file mode 100644
index 0000000..8c9157d
--- /dev/null
+++ b/setup.cfg
@@ -0,0 +1,8 @@
+[metadata]
+description-file = README.md
+
+[egg_info]
+tag_build =
+tag_date = 0
+tag_svn_revision = 0
+
diff --git a/setup.py b/setup.py
new file mode 100644
index 0000000..85c5c84
--- /dev/null
+++ b/setup.py
@@ -0,0 +1,15 @@
+#!/usr/bin/env python
+
+from setuptools import setup
+
+setup(name='zenoss',
+
+version='0.6.2',
+ description='Module to work with the Zenoss JSON API.',
+ author="Seth Miller",
+ author_email='seth at sethmiller.me',
+ url='https://github.com/iamseth/python-zenoss',
+ py_modules=['zenoss',],
+ keywords = ['zenoss', 'api', 'json', 'rest'],
+ test_suite='tests'
+)
diff --git a/zenoss.egg-info/PKG-INFO b/zenoss.egg-info/PKG-INFO
new file mode 100644
index 0000000..289862f
--- /dev/null
+++ b/zenoss.egg-info/PKG-INFO
@@ -0,0 +1,11 @@
+Metadata-Version: 1.0
+Name: zenoss
+Version: 0.6.2
+Summary: Module to work with the Zenoss JSON API.
+Home-page: https://github.com/iamseth/python-zenoss
+Author: Seth Miller
+Author-email: seth at sethmiller.me
+License: UNKNOWN
+Description: UNKNOWN
+Keywords: zenoss,api,json,rest
+Platform: UNKNOWN
diff --git a/zenoss.egg-info/SOURCES.txt b/zenoss.egg-info/SOURCES.txt
new file mode 100644
index 0000000..eafa211
--- /dev/null
+++ b/zenoss.egg-info/SOURCES.txt
@@ -0,0 +1,8 @@
+setup.cfg
+setup.py
+zenoss.py
+zenoss.egg-info/PKG-INFO
+zenoss.egg-info/SOURCES.txt
+zenoss.egg-info/dependency_links.txt
+zenoss.egg-info/pbr.json
+zenoss.egg-info/top_level.txt
\ No newline at end of file
diff --git a/zenoss.egg-info/dependency_links.txt b/zenoss.egg-info/dependency_links.txt
new file mode 100644
index 0000000..8b13789
--- /dev/null
+++ b/zenoss.egg-info/dependency_links.txt
@@ -0,0 +1 @@
+
diff --git a/zenoss.egg-info/pbr.json b/zenoss.egg-info/pbr.json
new file mode 100644
index 0000000..b548629
--- /dev/null
+++ b/zenoss.egg-info/pbr.json
@@ -0,0 +1 @@
+{"is_release": false, "git_version": "e478c34"}
\ No newline at end of file
diff --git a/zenoss.egg-info/top_level.txt b/zenoss.egg-info/top_level.txt
new file mode 100644
index 0000000..bcb1476
--- /dev/null
+++ b/zenoss.egg-info/top_level.txt
@@ -0,0 +1 @@
+zenoss
diff --git a/zenoss.py b/zenoss.py
new file mode 100755
index 0000000..6e35129
--- /dev/null
+++ b/zenoss.py
@@ -0,0 +1,287 @@
+'''Python module to work with the Zenoss JSON API
+'''
+import ast
+import re
+import json
+import logging
+import requests
+
+log = logging.getLogger(__name__) # pylint: disable=C0103
+requests.packages.urllib3.disable_warnings()
+
+ROUTERS = {'MessagingRouter': 'messaging',
+ 'EventsRouter': 'evconsole',
+ 'ProcessRouter': 'process',
+ 'ServiceRouter': 'service',
+ 'DeviceRouter': 'device',
+ 'NetworkRouter': 'network',
+ 'TemplateRouter': 'template',
+ 'DetailNavRouter': 'detailnav',
+ 'ReportRouter': 'report',
+ 'MibRouter': 'mib',
+ 'ZenPackRouter': 'zenpack'}
+
+
+class ZenossException(Exception):
+ '''Custom exception for Zenoss
+ '''
+ pass
+
+
+class Zenoss(object):
+ '''A class that represents a connection to a Zenoss server
+ '''
+ def __init__(self, host, username, password, ssl_verify=True):
+ self.__host = host
+ self.__session = requests.Session()
+ self.__session.auth = (username, password)
+ self.__session.verify = ssl_verify
+ self.__req_count = 0
+
+ def __router_request(self, router, method, data=None):
+ '''Internal method to make calls to the Zenoss request router
+ '''
+ if router not in ROUTERS:
+ raise Exception('Router "' + router + '" not available.')
+
+ req_data = json.dumps([dict(
+ action=router,
+ method=method,
+ data=data,
+ type='rpc',
+ tid=self.__req_count)])
+
+ log.debug('Making request to router %s with method %s', router, method)
+ uri = '%s/zport/dmd/%s_router' % (self.__host, ROUTERS[router])
+ headers = {'Content-type': 'application/json; charset=utf-8'}
+ response = self.__session.post(uri, data=req_data, headers=headers)
+ self.__req_count += 1
+
+ # The API returns a 200 response code even whe auth is bad.
+ # With bad auth, the login page is displayed. Here I search for
+ # an element on the login form to determine if auth failed.
+
+ if re.search('name="__ac_name"', response.content.decode("utf-8")):
+ log.error('Request failed. Bad username/password.')
+ raise ZenossException('Request failed. Bad username/password.')
+
+ return json.loads(response.content.decode("utf-8"))['result']
+
+ def get_rrd_values(self, device, dsnames, start=None, end=None, function='LAST'): # pylint: disable=R0913
+ '''Method to abstract the details of making a request to the getRRDValue method for a device
+ '''
+ if function not in ['MINIMUM', 'AVERAGE', 'MAXIMUM', 'LAST']:
+ raise ZenossException('Invalid RRD function {0} given.'.format(function))
+
+ if len(dsnames) == 1:
+ # Appending a junk value to dsnames because if only one value is provided Zenoss fails to return a value.
+ dsnames.append('junk')
+
+ url = '{0}/{1}/getRRDValues'.format(self.__host, self.device_uid(device))
+ params = {'dsnames': dsnames, 'start': start, 'end': end, 'function': function}
+ return ast.literal_eval(self.__session.get(url, params=params).content)
+
+ def get_devices(self, device_class='/zport/dmd/Devices', limit=None):
+ '''Get a list of all devices.
+
+ '''
+ log.info('Getting all devices')
+ return self.__router_request('DeviceRouter', 'getDevices',
+ data=[{'uid': device_class, 'params': {}, 'limit': limit}])
+
+ def find_device(self, device_name):
+ '''Find a device by name.
+
+ '''
+ log.info('Finding device %s', device_name)
+ all_devices = self.get_devices()
+
+ try:
+ device = [d for d in all_devices['devices'] if d['name'] == device_name][0]
+ # We need to save the has for later operations
+ device['hash'] = all_devices['hash']
+ log.info('%s found', device_name)
+ return device
+ except IndexError:
+ log.error('Cannot locate device %s', device_name)
+ raise Exception('Cannot locate device %s' % device_name)
+
+ def device_uid(self, device):
+ '''Helper method to retrieve the device UID for a given device name
+ '''
+ return self.find_device(device)['uid']
+
+ def add_device(self, device_name, device_class, collector='localhost'):
+ '''Add a device.
+
+ '''
+ log.info('Adding %s', device_name)
+ data = dict(deviceName=device_name, deviceClass=device_class, model=True, collector=collector)
+ return self.__router_request('DeviceRouter', 'addDevice', [data])
+
+ def remove_device(self, device_name):
+ '''Remove a device.
+
+ '''
+ log.info('Removing %s', device_name)
+ device = self.find_device(device_name)
+ data = dict(uids=[device['uid']], hashcheck=device['hash'], action='delete')
+ return self.__router_request('DeviceRouter', 'removeDevices', [data])
+
+ def move_device(self, device_name, organizer):
+ '''Move the device the organizer specified.
+
+ '''
+ log.info('Moving %s to %s', device_name, organizer)
+ device = self.find_device(device_name)
+ data = dict(uids=[device['uid']], hashcheck=device['hash'], target=organizer)
+ return self.__router_request('DeviceRouter', 'moveDevices', [data])
+
+ def set_prod_state(self, device_name, prod_state):
+ '''Set the production state of a device.
+
+ '''
+ log.info('Setting prodState on %s to %s', device_name, prod_state)
+ device = self.find_device(device_name)
+ data = dict(uids=[device['uid']], prodState=prod_state, hashcheck=device['hash'])
+ return self.__router_request('DeviceRouter', 'setProductionState', [data])
+
+ def set_maintenance(self, device_name):
+ '''Helper method to set prodState for device so that it does not alert.
+
+ '''
+ return self.set_prod_state(device_name, 300)
+
+ def set_production(self, device_name):
+ '''Helper method to set prodState for device so that it is back in production and alerting.
+
+ '''
+ return self.set_prod_state(device_name, 1000)
+
+ def set_product_info(self, device_name, hw_manufacturer, hw_product_name, os_manufacturer, os_product_name): # pylint: disable=R0913
+ '''Set ProductInfo on a device.
+
+ '''
+ log.info('Setting ProductInfo on %s', device_name)
+ device = self.find_device(device_name)
+ data = dict(uid=device['uid'],
+ hwManufacturer=hw_manufacturer,
+ hwProductName=hw_product_name,
+ osManufacturer=os_manufacturer,
+ osProductName=os_product_name)
+ return self.__router_request('DeviceRouter', 'setProductInfo', [data])
+
+ def set_rhel_release(self, device_name, release):
+ '''Sets the proper release of RedHat Enterprise Linux.'''
+ if type(release) is not float:
+ log.error("RHEL release must be a float")
+ return {u'success': False}
+ log.info('Setting RHEL release on %s to %s', device_name, release)
+ device = self.find_device(device_name)
+ return self.set_product_info(device_name, device['hwManufacturer']['name'], device['hwModel']['name'], 'RedHat',
+ 'RHEL {}'.format(release))
+
+ def set_device_info(self, device_name, data):
+ '''Set attributes on a device or device organizer.
+ This method accepts any keyword argument for the property that you wish to set.
+
+ '''
+ data['uid'] = self.find_device(device_name)['uid']
+ return self.__router_request('DeviceRouter', 'setInfo', [data])
+
+ def remodel_device(self, device_name):
+ '''Submit a job to have a device remodeled.
+
+ '''
+ return self.__router_request('DeviceRouter', 'remodel', [dict(uid=self.find_device(device_name)['uid'])])
+
+ def set_collector(self, device_name, collector):
+ '''Set collector for device.
+
+ '''
+ device = self.find_device(device_name)
+ data = dict(uids=[device['uid']], hashcheck=device['hash'], collector=collector)
+ return self.__router_request('DeviceRouter', 'setCollector', [data])
+
+ def rename_device(self, device_name, new_name):
+ '''Rename a device.
+
+ '''
+ data = dict(uid=self.find_device(device_name)['uid'], newId=new_name)
+ return self.__router_request('DeviceRouter', 'renameDevice', [data])
+
+ def reset_ip(self, device_name, ip_address=''):
+ '''Reset IP address(es) of device to the results of a DNS lookup or a manually set address.
+
+ '''
+ device = self.find_device(device_name)
+ data = dict(uids=[device['uid']], hashcheck=device['hash'], ip=ip_address)
+ return self.__router_request('DeviceRouter', 'resetIp', [data])
+
+ def get_events(self, device=None, limit=100, component=None, event_class=None):
+ '''Find current events.
+
+ '''
+ data = dict(start=0, limit=limit, dir='DESC', sort='severity')
+ data['params'] = dict(severity=[5, 4, 3, 2], eventState=[0, 1])
+ if device:
+ data['params']['device'] = device
+ if component:
+ data['params']['component'] = component
+ if event_class:
+ data['params']['eventClass'] = event_class
+ log.info('Getting events for %s', data)
+ return self.__router_request('EventsRouter', 'query', [data])['events']
+
+ def get_event_detail(self, event_id):
+ '''Find specific event details
+
+ '''
+ data = dict(evid=event_id)
+ return self.__router_request('EventsRouter', 'detail', [data])
+
+ def write_log(self, event_id, message):
+ '''Write a message to the event's log
+
+ '''
+ data = dict(evid=event_id, message=message)
+ return self.__router_request('EventsRouter', 'write_log', [data])
+
+ def change_event_state(self, event_id, state):
+ '''Change the state of an event.
+
+ '''
+ log.info('Changing eventState on %s to %s', event_id, state)
+ return self.__router_request('EventsRouter', state, [{'evids': [event_id]}])
+
+ def ack_event(self, event_id):
+ '''Helper method to set the event state to acknowledged.
+
+ '''
+ return self.change_event_state(event_id, 'acknowledge')
+
+ def close_event(self, event_id):
+ '''Helper method to set the event state to closed.
+
+ '''
+ return self.change_event_state(event_id, 'close')
+
+ def create_event_on_device(self, device_name, severity, summary):
+ '''Manually create a new event for the device specified.
+
+ '''
+ log.info('Creating new event for %s with severity %s', device_name, severity)
+ if severity not in ('Critical', 'Error', 'Warning', 'Info', 'Debug', 'Clear'):
+ raise Exception('Severity %s is not valid.' % severity)
+ data = dict(device=device_name, summary=summary, severity=severity, component='', evclasskey='', evclass='')
+ return self.__router_request('EventsRouter', 'add_event', [data])
+
+ def get_load_average(self, device):
+ '''Returns the current 1, 5 and 15 minute load averages for a device.
+ '''
+ dsnames = ('laLoadInt1_laLoadInt1', 'laLoadInt5_laLoadInt5', 'laLoadInt15_laLoadInt15')
+ result = self.get_rrd_values(device=device, dsnames=dsnames)
+ def normalize_load(load):
+ '''Convert raw RRD load average to something reasonable so that it matches output from /proc/loadavg'''
+ return round(float(load) / 100.0, 2)
+ return [normalize_load(l) for l in result.values()]
--
Alioth's /usr/local/bin/git-commit-notice on /srv/git.debian.org/git/python-modules/packages/python-zenoss.git
More information about the Python-modules-commits
mailing list