#!/usr/bin/python
# Copyright 2012 Rackspace Hosting {{{
#
# Contact - Nate House nathan.house@rackspace.com
#
# Licensed under the Apache License, Version 2.0 (the "License");
# you may not use this file except in compliance with the License.
# You may obtain a copy of the License at
#
# http://www.apache.org/licenses/LICENSE-2.0
#
# Unless required by applicable law or agreed to in writing, software
# distributed under the License is distributed on an "AS IS" BASIS,
# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
# See the License for the specific language governing permissions and
# limitations under the License.
#
# }}}
from Cloud import *
#Setup logger. Root logger config in _Globals.py
log = logging.getLogger(__name__)
#log.setLevel(logging.DEBUG)
[docs]class CloudMonitor(Cloud):
service = "Monitoring"
#Account {{{
[docs] def getAccount(self):
"""
Returns account information.
Arguments:
Returns: JSON results as python dict
"""
self.baseURL('account')
log.info("getAccount GET to %s" % self.endpoint)
return apiRequest(self, self.endpoint, "GET", returnResults=True)
[docs] def updateAccount(self, metaDict={}, token=None):
"""
Update properties on an account.
Arguments:
metaDict - metadata key-value pairs in form of python dictionary (Optional)
token -- webhook token (Optional)
Returns: status code
"""
self.baseURL('account')
self.attrDict = metaDict
self.postKey = 'metadata'
#optional args
self.postVar('webhook_token',token)
self.postKeyDict()
log.info("updateAccount PUT to %s with data - %s" % (self.endpoint, str(self.postData)))
return apiRequest(self, self.endpoint, "PUT", self.postData)
[docs] def getLimits(self):
"""
Returns account resource limits.
Arguments:
Returns: JSON results as python dict
"""
self.baseURL('limits')
log.info("getLimits GET to %s" % self.endpoint)
return apiRequest(self, self.endpoint, "GET", returnResults=True)
[docs] def getAudits(self, limit=None, From=None, To=None, reverse=False, marker=None):
#def getAudits(self, *args, **kwargs):
"""
Lists audits for this account.
Arguments:
From -- query start date*
To -- query end date*
reverse -- enabled specifying that time sequenced data be returned in reverse order
marker -- used to mark query when retrieving info in subsequent queries
limit -- when not specifed in the endpoint actually defaults to 100
* *These parameters take integer values, which are interpreted as timestamps expressed in milliseconds since 00:00:00 UTC on January 1, 1970. If the to value is not specified it defaults to the current time. Each time series collection specifies a default offset from the current time, which is used when the from value is not supplied. For example, if no to or from values are specified when retrieving an alarm history, then it will be treated as a query for the last 7 days of data.
To convert a particular time to UTC, you can use the date +%s000 command or a website such as
http://www.epochconverter.com/
If no 'to' or 'from' values are specified, then it will be treated as a query for the last 7 days of data.
Returns: JSON results as python dict
"""
self.baseURL('audits')
if From:
self.queryVar('from', From)
if To:
self.queryVar('to', To)
if reverse:
self.queryVar('reverse', reverse)
if marker:
self.queryVar('marker', marker)
if limit:
self.queryVar('limit', limit)
log.info("getAudits GET to %s" % self.endpoint)
return apiRequest(self, self.endpoint, "GET", returnResults=True)
# }}}
#Entities {{{
[docs] def getEntities(self, limit=None, From=None, To=None, reverse=False, marker=None):
"""
Lists the entities on the account.
Arguments:
From -- query start date*
To -- query end date*
reverse -- enabled specifying that time sequenced data be returned in reverse order
marker -- used to mark query when retrieving info in subsequent queries
limit -- when not specifed in the endpoint actually defaults to 100
* *These parameters take integer values, which are interpreted as timestamps expressed in milliseconds since 00:00:00 UTC on January 1, 1970. If the to value is not specified it defaults to the current time. Each time series collection specifies a default offset from the current time, which is used when the from value is not supplied. For example, if no to or from values are specified when retrieving an alarm history, then it will be treated as a query for the last 7 days of data.
To convert a particular time to UTC, you can use the date +%s000 command or a website such as
http://www.epochconverter.com/
If no 'to' or 'from' values are specified, then it will be treated as a query for the last 7 days of data.
Returns: JSON results as python dict, including 'metadata'
"""
self.baseURL('entities')
if From:
self.queryVar('from', From)
if To:
self.queryVar('to', To)
if reverse:
self.queryVar('reverse', reverse)
if marker:
self.queryVar('marker', marker)
if limit:
self.queryVar('limit', limit)
log.info("getEntities GET to %s" % self.endpoint)
return apiRequest(self, self.endpoint, "GET", returnResults=True)
[docs] def getEntity(self, eId):
"""
Retrieves the current state of an entity.
Arguments:
eId -- entity id
Returns: JSON results as python dict
"""
self.baseURL('entities/'+str(eId))
log.info("getEntity GET to %s" % self.endpoint)
return apiRequest(self, self.endpoint, "GET", returnResults=True)
[docs] def createEntity(self, label, attrDict={}):
"""
Creates a new entity.
Arguments:
label --
attrDict -- python dictionary of arg options:
agent_id -- (Optional)
ip_addresses - ip's in form of python dictionary (Optional)
metadata - metadata key-value pairs in form of python dictionary (Optional)
Returns: status code
"""
self.baseURL('entities')
self.attrDict = attrDict
#required args
self.postVar('label',label)
#optional args
self.postDict()
log.info("createEntity POST to %s with data - %s" % (self.endpoint, str(self.postData)))
return apiRequest(self, self.endpoint, "POST", self.postData)
[docs] def updateEntity(self, eId, label, attrDict={}):
"""
Updates an entity specified by the entityId (id).
Arguments:
eId -- entity id
label -- (Optional)
attrDict -- python dictionary of arg options:
agent_id -- (Optional)
ip_addresses - ip's in form of python dictionary (Optional)
metadata - metadata key-value pairs in form of python dictionary (Optional)
Returns: status code
"""
self.baseURL('entities/'+str(eId))
self.attrDict = attrDict
#required args
self.postVar('label',label)
#optional args
self.postDict()
log.info("updateEntity PUT to %s with data - %s" % (self.endpoint, str(self.postData)))
return apiRequest(self, self.endpoint, "PUT", self.postData)
[docs] def deleteEntity(self, eId):
"""
Delete an entity.
Arguments:
eId -- entity id
Returns: status code
"""
self.baseURL('entities/'+str(eId))
log.info("deleteEntity DELETE to %s" % self.endpoint)
return apiRequest(self, self.endpoint, "DELETE")
# }}}
#Checks {{{
[docs] def createCheck(self, entityId, attrDict={}, testMode=False):
"""
Creates (or test creates) a new check associated with an entity.
Arguments:
entityId --
attrDict -- python dictionary of options:
type -- remote.dns / remote.ssh / remote.smtp / remote.http /
remote.tcp / remote.ping / remote.ftp-banner / remote.imap-banner /
remote.pop3-banner / remote.smtp-banner / remote.postgresql-banner /
remote.telnet-banner / remote.mysql-banner /
remote.mssql-banner (Required)
details -- (Optional)
disabled -- (Optional)
label -- (Optional)
metadataDict -- metadata python dict of key/value pairs (Optional)
period -- (Optional)
timeout -- (Optional)
monitoringZonesPoll -- (for remote checks) (Optional)
targetAlias -- (for remote checks) (Optional)
targetHost -- (for remote checks) (Optional)
targetResolver -- (for remote checks) (Optional)
testMode -- true/false (default=True)
Returns: status code
"""
if testMode:
self.baseURL('entities/'+str(entityId)+'/test-check')
else:
self.baseURL('entities/'+str(entityId)+'/checks')
self.attrDict = attrDict
#required + optional args
self.postDict()
if testMode:
log.info("createCheck POST to %s with data - %s" % (self.endpoint, str(self.postData)))
return apiRequest(self, self.endpoint, "POST", self.postData, returnResults=True)
else:
log.info("createCheck POST to %s with data - %s" % (self.endpoint, str(self.postData)))
return apiRequest(self, self.endpoint, "POST", self.postData)
[docs] def testCheck(self, entityId, attrDict={}):
"""
Tests the creation of a new check associated with an entity.
Arguments:
entityId -- entity id
attrDict -- python dictionary:
type -- remote.dns / remote.ssh / remote.smtp / remote.http /
remote.tcp / remote.ping / remote.ftp-banner / remote.imap-banner /
remote.pop3-banner / remote.smtp-banner / remote.postgresql-banner /
remote.telnet-banner / remote.mysql-banner / remote.mssql-banner
details -- (Optional)
disabled -- (Optional)
label -- (Optional)
metadataDict -- metadata python dict of key/value pairs (Optional)
period -- (Optional)
timeout -- (Optional)
monitoringZonesPoll -- (for remote checks) (Optional)
targetAlias -- (for remote checks) (Optional)
targetHost -- (for remote checks) (Optional)
targetResolver -- (for remote checks) (Optional)
Returns: status code
"""
return self.createCheck(entityId, attrDict, True)
[docs] def getCheck(self, entityId, checkId):
"""
Returns the specified check.
Arguments:
entityId --
checkId --
Returns: status code.
"""
self.baseURL('entities/'+str(entityId)+'/checks/'+str(checkId))
log.info("getCheck GET to %s" % self.endpoint)
return apiRequest(self, self.endpoint, "GET", returnResults=True)
[docs] def getChecks(self, entityId):
"""
Lists checks associated with an entityId.
Arguments:
entityId --
Returns: JSON results as python dict
"""
self.postData={}
self.baseURL('entities/'+str(entityId)+'/checks')
log.info("getChecks GET to %s" % self.endpoint)
return apiRequest(self, self.endpoint, "GET", returnResults=True)
[docs] def testRunCheck(self, entityId, checkId):
"""
Test a check inline.
Arguments:
entityId --
checkId --
Returns: status code.
"""
self.baseURL('entities/'+str(entityId)+'/checks/'+str(checkId)+'/test')
log.info("testRunCheck POST to %s with data - %s" % (self.endpoint, str(self.postData)))
return apiRequest(self, self.endpoint, "POST", returnResults=True)
[docs] def updateCheck(self, entityId, checkId, attrDict={}):
"""
Updates a check associated with an entity.
Arguments:
entityId --
attrDict -- python dictionary or optional args:
type -- remote.dns / remote.ssh / remote.smtp / remote.http /
remote.tcp / remote.ping / remote.ftp-banner / remote.imap-banner /
remote.pop3-banner / remote.smtp-banner / remote.postgresql-banner /
remote.telnet-banner / remote.mysql-banner / remote.mssql-banner (Required)
details -- (Optional)
disabled -- (Optional)
label -- (Optional)
metadata -- metadata python dict of key/value pairs (Optional)
period -- (Optional)
timeout -- (Optional)
monitoringZonePoll -- (for remote checks) (Optional)
targetAlias -- (for remote checks) (Optional)
targetHost -- (for remote checks) (Optional)
targetResolver -- (for remote checks) (Optional)
Returns: status code
"""
self.baseURL('entities/'+str(entityId)+'/checks/'+str(checkId))
self.attrDict = attrDict
log.info("updateCheck PUT to %s with data - %s" % (self.endpoint, str(self.postData)))
return apiRequest(self, self.endpoint, "PUT", self.postData)
[docs] def deleteCheck(self, entityId, checkId):
"""
Deletes a check.
Arguments:
entityId --
checkId --
Returns: status code
"""
self.baseURL('entities/'+str(entityId)+'/checks/'+str(checkId))
log.info("deleteCheck DELETE to %s" % self.endpoint)
return apiRequest(self, self.endpoint, "DELETE")
# }}}
#Check Types {{{
[docs] def getCheckType(self, id):
"""
Returns the specified check type.
Arguments:
id -- check type id
Returns: status code.
"""
self.baseURL('check_types/'+str(id))
log.info("getCheckType GET to %s" % self.endpoint)
return apiRequest(self, self.endpoint, "GET", returnResults=True)
[docs] def getCheckTypes(self):
"""
List available check types.
Arguments:
Returns: JSON results as python dict
"""
self.baseURL('check_types')
return apiRequest(self, self.endpoint, "GET", returnResults=True)
# }}}
#Alarms {{{
[docs] def createAlarm(self, entityId, checkId, planId, attrDict={}, testMode=False):
"""
Create (or test run the creation of) a(n) new alarm.
Arguments:
entityId --
checkId -- The ID of the check to alert on. (string)
planId -- The ID of the notification plan to execute when the state changes.
attrDict -- python dict options:
criteria -- (Optional)
disabled -- Disable processing and alerts on this alarm (Optional)(Boolean)
label -- (Optional)
metadata -- python dict of metadata key value pairs (Optional)
testMode -- true/false (default=False)
Returns: status code
"""
if testMode:
self.baseURL('entities/'+str(entityId)+'/test-alarm')
else:
self.baseURL('entities/'+str(entityId)+'/alarms')
self.attrDict = attrDict
#required args
self.postVar('check_id',checkId)
self.postVar('notification_plan_id',planId)
#optional args
self.postDict()
if testMode:
log.info("createAlarm POST to %s with data - %s" % (self.endpoint, str(self.postData)))
return apiRequest(self, self.endpoint, "POST", self.postData, returnResults=True)
else:
log.info("createAlarm POST to %s with data - %s" % (self.endpoint, str(self.postData)))
return apiRequest(self, self.endpoint, "POST", self.postData)
[docs] def testAlarm(self, entityId, checkId, planId, attrDict={}):
"""
Test run the creation of an alarm.
Arguments:
entityId --
checkId --
planId -- notification plan id
attrDict -- python dict options:
criteria -- (Optional)
label -- (Optional)
metadataDict -- python dict of metadata key value pairs (Optional)
Returns: status code
"""
return self.createAlarm(entityId, checkId, planId, attrDict, True)
[docs] def getAlarm(self, entityId, alarmId):
"""
Returns the specified alarm.
Arguments:
entityId --
alarmId --
Returns: status code.
"""
self.baseURL('entities/'+str(entityId)+'/alarms/'+str(alarmId))
log.info("getAlarm GET to %s" % self.endpoint)
return apiRequest(self, self.endpoint, "GET", self.postData, returnResults=True)
[docs] def getAlarms(self, entityId):
"""
Lists alarms associated with an entityId.
Arguments:
entityId --
Returns: JSON results as python dict
"""
self.baseURL('entities/'+str(entityId)+'/alarms')
log.info("getAccount GET to %s" % self.endpoint)
return apiRequest(self, self.endpoint, "GET", self.postData, returnResults=True)
[docs] def updateAlarm(self, entityId, alarmId, attrDict={}):
"""
Update an alarm associated with an entity.
Update an alarm with the specified alarmId. Partial updates to an alarm are acceptable. You may specify only the parameters you would like to update.
Arguments:
entityId --
alarmId --
attrDict -- python dict options:
checkId -- The ID of the check to alert on.
planId -- notification plan id (Optional)
criteria -- (Optional)
label -- (Optional)
disabled -- Disable processing and alerts on this alarm (Optional) (Boolean)
metadataDict -- python dict of metadata key value pairs (Optional)
Returns: status code
"""
self.baseURL('entities/'+str(entityId)+'/alarms/'+str(alarmId))
self.attrDict = attrDict
#optional args
self.postDict()
#return apiRequest(self, self.endpoint, "PUT", self.postData, returnResults=True)
log.info("updateAccount PUT to %s with data - %s" % (self.endpoint, str(self.postData)))
return apiRequest(self, self.endpoint, "PUT", self.postData)
[docs] def deleteAlarm(self, entityId, alarmId):
"""
Deletes an alarm.
Arguments:
entityId --
alarmId --
Returns: status code
"""
self.baseURL('entities/'+str(entityId)+'/alarms/'+str(alarmId))
log.info("deleteAlarm DELETE to %s" % self.endpoint)
return apiRequest(self, self.endpoint, "DELETE")
# }}}
#Notification Plans {{{
[docs] def createNPlan(self, label, attrDict={}): # criticalState, okState, warningState):
"""
Creates a notification plan.
Arguments:
label --
attrDict -- python dict options:
critical_state --
ok_state --
warning_state --
Returns: status code
"""
self.baseURL('notification_plans')
self.attrDict = attrDict
#optional args
self.postVar('label',label)
self.postDict()
#print self.endpoint
#print self.postData
#return apiRequest(self, self.endpoint, "POST", self.postData, returnResults=True)
log.info("createNPlan POST to %s with data - %s" % (self.endpoint, str(self.postData)))
return apiRequest(self, self.endpoint, "POST", self.postData)
[docs] def getNPlans(self):
"""
Lists notification plans for current account.
Arguments:
Returns: JSON results as python dict
"""
self.baseURL('notification_plans')
log.info("getNPlans GET to %s" % self.endpoint)
return apiRequest(self, self.endpoint, "GET", returnResults=True)
[docs] def getNPlan(self, npId):
"""
Returns the specified notification plan.
Arguments:
nplanId --
Returns: status code.
"""
self.baseURL('notification_plans/'+str(npId))
log.info("getNPlan GET to %s" % self.endpoint)
return apiRequest(self, self.endpoint, "GET", returnResults=True)
[docs] def updateNPlan(self, npId, attrDict={}):
"""
Update a notification plan associated with an entity.
Arguments:
nplanId --
attrDict -- python dict of option args:
label --
critical_state --
ok_state --
warning_state --
Returns: status code
"""
self.baseURL('notification_plans/'+str(npId))
self.attrDict = attrDict
self.postDict()
log.info("updateNPlan PUT to %s with data - %s" % (self.endpoint, str(self.postData)))
return apiRequest(self, self.endpoint, "PUT", self.postData)
[docs] def deleteNPlan(self, npId):
"""
Deletes a notification plan.
Arguments:
entityId --
nplanId --
Returns: status code
"""
self.baseURL('notification_plans/'+str(npId))
log.info("deleteNPlan DELETE to %s" % self.endpoint)
return apiRequest(self, self.endpoint, "DELETE")
# }}}
#Monitoring Zones {{{
[docs] def getMZones(self):
"""
List monitoring zones.
Arguments:
Returns: JSON results as python dict
"""
self.baseURL('monitoring_zones')
log.info("getMZones GET to %s" % self.endpoint)
return apiRequest(self, self.endpoint, "GET", returnResults=True)
[docs] def getMZone(self, mzoneId):
"""
Returns the specified monitoring zone.
Arguments:
mzoneId --
Returns: status code.
"""
self.baseURL('monitoring_zones/'+str(mzoneId))
log.info("getMZone GET to %s" % self.endpoint)
return apiRequest(self, self.endpoint, "GET", self.postData, returnResults=True)
[docs] def traceMZone(self, mzoneId, target, attrDict={}):
"""
Perform a traceroute from a collector in the specified monitoring zones.
Arguments:
mzoneId --
target -- target ip or hostname
attrDict -- python dict options:
targetResolver -- IPv6 / IPv6 (Optional)
Returns: status code.
"""
self.baseURL('monitoring_zones/'+str(mzoneId)+'/traceroute')
self.attrDict = attrDict
self.postVar('target',target)
self.postDict()
log.info("traceMZone POST to %s with data - %s" % (self.endpoint, str(self.postData)))
return apiRequest(self, self.endpoint, "POST", self.postData, returnResults=True)
# }}}
#Alarm Notification History {{{
[docs] def discoverAlarmHistory(self, entityId, alarmId):
"""
List checks for which alarm notification history is available.
Arguments:
entityId --
alarmId --
Returns: JSON results as python dict
"""
self.baseURL('entities/'+str(entityId)+'/alarms/'+str(alarmId)+'/notification_history')
log.info("discoverAlarmHistory GET to %s" % self.endpoint)
return apiRequest(self, self.endpoint, "GET", self.postData, returnResults=True)
[docs] def getAlarmHistory(self, entityId, alarmId, checkId, uuid=None):
"""
List checks for which alarm notification history is available -- or if
uuid is provided, retrieves a single alarm notification history item.
Arguments:
entityId --
alarmId --
checkId --
uuid -- id of a single alarm notification history item (Optional)
Returns: JSON results as python dict
"""
if uuid:
self.baseURL('entities/'+str(entityId)+'/alarms/'+str(alarmId)+'/notification_history/'+str(checkId)+'/'+str(uuid))
else:
self.baseURL('entities/'+str(entityId)+'/alarms/'+str(alarmId)+'/notification_history/'+str(checkId))
log.info("getAlarmHistory GET to %s" % self.endpoint)
return apiRequest(self, self.endpoint, "GET", returnResults=True)
# }}}
#Notifications {{{
[docs] def createNotification(self, label, type, details, testMode=False):
"""
Create (or test the creation of ) a notification.
Arguments:
label --
type -- webhook / email
details --
testMode -- true/false (default=False)
Returns: status code
"""
self.baseURL('notifications')
self.postVar('details',details)
self.postVar('label',label)
self.postVar('type',type)
log.info("createNotification POST to %s with data - %s" % (self.endpoint, str(self.postData)))
return apiRequest(self, self.endpoint, "POST", self.postData)
[docs] def testNotification(self, label, type, details):
"""
Tests the creation of a notification.
Arguments:
label --
type -- webhook / email
details --
Returns: status code
"""
return self.createNotification(label,type,details,True)
[docs] def getNotification(self, noteId):
"""
Returns the specified notification.
Arguments:
noteId --
Returns: status code.
"""
self.baseURL('notifications/'+str(noteId))
log.info("getNotification GET to %s" % self.endpoint)
return apiRequest(self, self.endpoint, "GET", returnResults=True)
[docs] def getNotifications(self):
"""
Lists notifications.
Arguments:
Returns: JSON results as python dict
"""
self.baseURL('notifications')
log.info("getNotifications GET to %s" % self.endpoint)
return apiRequest(self, self.endpoint, "GET", returnResults=True)
[docs] def testRunNotification(self, noteId):
"""
Test a notification inline.
Arguments:
noteId --
Returns: status code.
"""
self.baseURL('notifications/'+str(noteId)+'/test')
log.info("testRunNotification POST to %s with data - %s" % (self.endpoint, str(self.postData)))
return apiRequest(self, self.endpoint, "POST", self.postData, returnResults=True)
[docs] def updateNotification(self, noteId, attrDict={}):
"""
Updates a notification.
Arguments:
noteId --
attrDict -- python dict options:
details --
label --
type -- webhook / email
Returns: status code
"""
self.baseURL('notifications/'+str(noteId))
self.attrDict = attrDict
#optional args
self.postDict()
log.info("updateNotification PUT to %s with data - %s" % (self.endpoint, str(self.postData)))
return apiRequest(self, self.endpoint, "PUT", self.postData)
[docs] def deleteNotification(self, noteId):
"""
Deletes a notification.
Arguments:
noteId --
Returns: status code
"""
self.baseURL('notifications/'+str(noteId))
log.info("deleteNotification DELETE to %s" % self.endpoint)
return apiRequest(self, self.endpoint, "DELETE")
# }}}
#Notification Types {{{
[docs] def getNotificationType(self, ntId):
"""
Returns the specified notification type.
Arguments:
ntId -- notification type id
Returns: status code.
"""
self.baseURL('notification_types/'+str(ntId))
log.info("getNotificationType GET to %s" % self.endpoint)
return apiRequest(self, self.endpoint, "GET", returnResults=True)
[docs] def getNotificationTypes(self):
"""
List available notification types.
Arguments:
Returns: JSON results as python dict
"""
self.baseURL('notification_types')
log.info("getNotificationTypes GET to %s" % self.endpoint)
return apiRequest(self, self.endpoint, "GET", returnResults=True)
# }}}
#Changelogs {{{
[docs] def getAlarmChangelogs(self, entityId=None):
"""
Lists alarm changelogs for this account, filtered by a given entity ID
Arguments:
entityId -- Entity ID, by which to filter results
Returns: JSON results as python dict
"""
self.baseURL('changelogs/alarms')
if entityId:
self.queryVar('entityId', entityId)
log.info("getAlarmChangelogs GET to %s" % self.endpoint)
return apiRequest(self, self.endpoint, "GET", returnResults=True)
# }}}
#Views {{{
[docs] def getOverview(self):
"""
Return the overview.
Arguments:
Returns: JSON results as python dict
"""
self.baseURL('views/overview')
log.info("getOverview GET to %s" % self.endpoint)
return apiRequest(self, self.endpoint, "GET", returnResults=True)
# }}}
#Alarm Examples {{{
[docs] def getAlarmExamples(self):
"""
Return list of alarm examples.
Arguments:
Returns: JSON results as python dict
"""
self.baseURL('alarm_examples')
log.info("getAlarmExamples GET to %s" % self.endpoint)
return apiRequest(self, self.endpoint, "GET", returnResults=True)
[docs] def getAlarmExample(self, aeId):
"""
Retrieve alarm example.
Arguments:
aeId -- alarm example id
Returns: status code.
"""
self.baseURL('alarm_examples/'+str(aeId))
log.info("getAlarmExample GET to %s" % self.endpoint)
return apiRequest(self, self.endpoint, "GET", returnResults=True)
[docs] def evalAlarmExample(self, aeId, evalDict):
"""
Evaluate alarm example.
Arguments:
aeId -- alarm example id
evalDict -- python dict of key/value pairs
Returns: status code.
"""
self.baseURL('alarm_examples/'+str(aeId))
self.postVar('values',evalDict)
log.info("evalAlarmExample POST to %s with data - %s" % (self.endpoint, str(self.postData)))
return apiRequest(self, self.endpoint, "POST", self.postData, returnResults=True)
# }}}
#eof