122 lines
3.9 KiB
Python
122 lines
3.9 KiB
Python
|
# Licensed to the Apache Software Foundation (ASF) under one
|
||
|
|
# or more contributor license agreements. See the NOTICE file
|
||
|
|
# distributed with this work for additional information
|
||
|
|
# regarding copyright ownership. The ASF licenses this file
|
||
|
|
# to you 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.
|
||
|
|
#
|
||
|
|
# $Id$
|
||
|
|
#
|
||
|
|
|
||
|
|
import sys
|
||
|
|
import os
|
||
|
|
from pysnmp.entity.rfc3413.oneliner import cmdgen
|
||
|
|
from pysnmp.proto import rfc1902
|
||
|
|
|
||
|
|
#import netsnmp
|
||
|
|
|
||
|
|
from systemmanagementinterface import SystemManagementInterface
|
||
|
|
|
||
|
|
|
||
|
|
#class systemmagement():
|
||
|
|
#def __init__(self, proto):
|
||
|
|
#self.proto = proto
|
||
|
|
|
||
|
|
class raritanDominionPx(SystemManagementInterface):
|
||
|
|
def __init__(self, host):
|
||
|
|
self.host = host['location']
|
||
|
|
self.pdu_name = host['pdu_name']
|
||
|
|
self.port = host['pdu_port']
|
||
|
|
self.user = host['pdu_userid']
|
||
|
|
self.password = host['pdu_password']
|
||
|
|
self.oid = "1,3,6,1,4,1,13742,4,1,2,2,1"
|
||
|
|
self.oid_name = ",2"
|
||
|
|
self.oid_set = ",3"
|
||
|
|
self.oid_status = ",3"
|
||
|
|
# this works
|
||
|
|
#errorIndication, errorStatus, errorIndex, varBinds = cmdgen.CommandGenerator().getCmd(cmdgen.CommunityData('my-agent', 'public', 0), cmdgen.UdpTransportTarget(('pdu0-r1r1', 161)), (1,3,6,1,4,1,13742,4,1,2,2,1,3,2))
|
||
|
|
|
||
|
|
#print varBinds
|
||
|
|
#oid = netsnmp.Varbind('sysDescr')
|
||
|
|
#result = netsnmp.snmpwalk(oid, Version = 2,DestHost="localhost",Community="public")
|
||
|
|
#print result
|
||
|
|
|
||
|
|
|
||
|
|
|
||
|
|
|
||
|
|
|
||
|
|
#var = netsnmp.Varbind('sysDescr.0')
|
||
|
|
#res = netsnmp.snmpget(var, ...:Version=1,...:DestHost = 'pdu0-r1r1',...: Community = 'prs-domain')
|
||
|
|
#print res
|
||
|
|
|
||
|
|
#print cmdgen
|
||
|
|
#set snmp = /usr/bin/snmpset -v 2c -c intel pdu .1.3.6.1.4.1.13742.4.1.2.2.1.3.$outletnumber i $state
|
||
|
|
#name snmp = /usr/bin/snmpset -v 2c -c intel pdu .1.3.6.1.4.1.13742.4.1.2.2.1.2.$outletnumber i $state
|
||
|
|
#status snmp = /usr/bin/snmpset -v 2c -c intel pdu .1.3.6.1.4.1.13742.4.1.2.2.1.1.$outletnumber i $state
|
||
|
|
#self.snmp_status_oid = ".1.3.6.1.4.1.13742.4.1.2.2.1.1."
|
||
|
|
#self.powerStatus = None
|
||
|
|
#print self.__dict__
|
||
|
|
|
||
|
|
def getPowerStatus(self):
|
||
|
|
thisoid = eval(str(self.oid) + str(self.oid_status) + "," + str(self.port))
|
||
|
|
errorIndication, errorStatus, errorIndex, varBinds = cmdgen.CommandGenerator().getCmd( \
|
||
|
|
cmdgen.CommunityData('my-agent', self.user, 0), \
|
||
|
|
cmdgen.UdpTransportTarget((self.pdu_name, 161)), thisoid)
|
||
|
|
output = varBinds[0][1]
|
||
|
|
|
||
|
|
if output == 1:
|
||
|
|
self.powerStatus = 1
|
||
|
|
powerstat = "on"
|
||
|
|
if output == 0:
|
||
|
|
self.powerStatus = 0
|
||
|
|
powerstat = "off"
|
||
|
|
|
||
|
|
print "PDU Power for %s is %s" % (self.host, powerstat)
|
||
|
|
|
||
|
|
if output:
|
||
|
|
return 1
|
||
|
|
return 0
|
||
|
|
|
||
|
|
|
||
|
|
def isPowered(self):
|
||
|
|
if self.powerStatus == None:
|
||
|
|
self.getPowerStatus()
|
||
|
|
if self.powerStatus:
|
||
|
|
return 1;
|
||
|
|
if not self.powerStatus:
|
||
|
|
return 0;
|
||
|
|
|
||
|
|
|
||
|
|
def powerOn(self):
|
||
|
|
thisoid = eval(str(self.oid) + str(self.oid_status) + "," + str(self.port))
|
||
|
|
errorIndication, errorStatus, errorIndex, varBinds = cmdgen.CommandGenerator().setCmd( \
|
||
|
|
cmdgen.CommunityData('my-agent', self.user, 1), \
|
||
|
|
cmdgen.UdpTransportTarget((self.pdu_name, 161)), \
|
||
|
|
(thisoid, rfc1902.Integer('1')))
|
||
|
|
self.getPowerStatus()
|
||
|
|
|
||
|
|
def powerOff(self):
|
||
|
|
thisoid = eval(str(self.oid) + str(self.oid_status) + "," + str(self.port))
|
||
|
|
errorIndication, errorStatus, errorIndex, varBinds = cmdgen.CommandGenerator().setCmd( \
|
||
|
|
cmdgen.CommunityData('my-agent', self.user, 1), \
|
||
|
|
cmdgen.UdpTransportTarget((self.pdu_name, 161)), \
|
||
|
|
(thisoid, rfc1902.Integer('0')))
|
||
|
|
self.getPowerStatus()
|
||
|
|
|
||
|
|
def powerCycle(self):
|
||
|
|
self.powerOff()
|
||
|
|
self.powerOn()
|
||
|
|
|
||
|
|
def powerReset(self):
|
||
|
|
self.powerCycle()
|