Add Eaton PDU driver.

Supports SNMP V3 only, with noAuth/noPriv enabled.

Change-Id: Ice7d1aa7375a48f497dc937e4aedfef0cf5fd434

etc/kwapi/drivers.conf

@@ -29,3 +29,13 @@ parameters = {'min': 10, 'max': 20}
 [Wattmeter 3]
 probes = ['C', 'D']
 driver = Dummy
+
+[Wattmeter 4]
+probes = ['E']
+driver = Ipmi
+parameters = {'cache_dir': '/tmp/kwapi-ipmi', 'interface':'lanplus', 'host':'192.168.0.70', 'password':'secret'}
+
+[Wattmeter 5]
+probes = ['F1', 'F2', 'F3', 'F4', 'F5', 'F6', 'F7', 'F8', 'F9', 'F10', 'F11', 'F12', 'F13', 'F14', 'F15', 'F16', 'F17', 'F18', 'F19', 'F20', 'F21', 'F22', 'F23', 'F24']
+driver = Eaton
+parameters = {'ip': '140.77.13.119', 'user': 'SNMPv3 User 1'}

kwapi/drivers/eaton.py

@@ -0,0 +1,81 @@
+# -*- coding: utf-8 -*-
+#
+# Author: François Rossigneux <francois.rossigneux@inria.fr>
+#
+# 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.
+
+import time
+
+from pysnmp.entity.rfc3413.oneliner import cmdgen
+
+from kwapi.openstack.common import log
+from driver import Driver
+
+LOG = log.getLogger(__name__)
+
+
+class Eaton(Driver):
+    """Driver for Eaton PDUs with 24 outlets."""
+
+    def __init__(self, probe_ids, **kwargs):
+        """Initializes the Eaton driver.
+
+        Keyword arguments:
+        probe_ids -- list containing the probes IDs
+                     (a wattmeter monitor sometimes several probes)
+        kwargs -- keyword (ip, user) defining the Eaton SNMP parameters
+
+        """
+        Driver.__init__(self, probe_ids, kwargs)
+        self.cmd_gen = cmdgen.CommandGenerator()
+
+    def run(self):
+        """Starts the driver thread."""
+        # Take measurements
+        while not self.stop_request_pending():
+            watts_list = self.get_watts()
+            if watts_list is not None:
+                i = 0
+                for watts in watts_list:
+                    measurements = {}
+                    measurements['w'] = watts
+                    self.send_measurements(self.probe_ids[i], measurements)
+                    i += 1
+            time.sleep(1)
+
+    def get_watts(self):
+        """Returns the power consumption."""
+        errorIndication, errorStatus, errorIndex, varBindTable = \
+            self.cmd_gen.bulkCmd(
+                cmdgen.UsmUserData(self.kwargs.get('user')),
+                cmdgen.UdpTransportTarget((self.kwargs.get('ip'), 161)),
+                1, 0,
+                '1.3.6.1.4.1.534.6.6.7.6.5.1.3',
+                maxRows=24,
+            )
+        if errorIndication:
+            LOG.error(errorIndication)
+            return None
+        else:
+            if errorStatus:
+                LOG.error('%s at %s' % (
+                    errorStatus.prettyPrint(),
+                    errorIndex and varBindTable[-1][int(errorIndex)-1] or '?'
+                ))
+                return None
+            else:
+                outlet_list = []
+                for varBindTableRow in varBindTable:
+                    for name, value in varBindTableRow:
+                        outlet_list.append(int(value))
+                return outlet_list

pip-requires

@@ -1,8 +1,9 @@
 flask
 iso8601
 pyserial
+pysnmp
 python-keystoneclient
 pyzmq
-python-rrdtool
+#python-rrdtool
 webob
 http://tarballs.openstack.org/oslo-config/oslo-config-2013.1b4.tar.gz#egg=oslo-config