From d64e26457e6c891304315a7de17db886493e8039 Mon Sep 17 00:00:00 2001
From: Mike Crute <mcrute@gmail.com>
Date: Fri, 27 Sep 2013 11:31:47 -0400
Subject: Adding unifi stats collection

---
 .gitignore             |   1 +
 collect_ssh.py         | 123 +++++++++++++++++++++++++++++++++++++++++++++++++
 parse_dumped_bodies.py |   2 +-
 requirements.txt       |   1 +
 utils.py               |  16 +++++++
 5 files changed, 142 insertions(+), 1 deletion(-)
 create mode 100755 collect_ssh.py
 create mode 100644 utils.py

diff --git a/.gitignore b/.gitignore
index e07a3b2..07469ec 100644
--- a/.gitignore
+++ b/.gitignore
@@ -1,2 +1,3 @@
 *.pyc
 .sandbox_name
+keystore.py
diff --git a/collect_ssh.py b/collect_ssh.py
new file mode 100755
index 0000000..607b774
--- /dev/null
+++ b/collect_ssh.py
@@ -0,0 +1,123 @@
+#!/usr/bin/env python
+
+import os
+import json
+import time
+import paramiko
+import contextlib
+import subprocess
+
+from keystore import USERNAME, PASSWORD, HOSTS
+
+
+RRA_COMMON = [
+    "RRA:AVERAGE:0.5:1:800",
+    "RRA:AVERAGE:0.5:6:800",
+    "RRA:AVERAGE:0.5:24:800",
+    "RRA:AVERAGE:0.5:288:800",
+    "RRA:MAX:0.5:1:800",
+    "RRA:MAX:0.5:6:800",
+    "RRA:MAX:0.5:24:800",
+    "RRA:MAX:0.5:288:800",
+]
+
+RRD_TEMPLATES = {
+    "interface": [
+        "DS:packets_rx:COUNTER:600:0:U",
+        "DS:packets_tx:COUNTER:600:0:U",
+        "DS:bytes_rx:COUNTER:600:0:U",
+        "DS:bytes_tx:COUNTER:600:0:U",
+        "DS:errors_rx:COUNTER:600:0:U",
+        "DS:errors_tx:COUNTER:600:0:U",
+        "DS:dropped_rx:COUNTER:600:0:U",
+        "DS:dropped_tx:COUNTER:600:0:U",
+    ],
+    "network": [
+        "DS:packets_rx:COUNTER:600:0:U",
+        "DS:packets_tx:COUNTER:600:0:U",
+        "DS:bytes_rx:COUNTER:600:0:U",
+        "DS:bytes_tx:COUNTER:600:0:U",
+        "DS:retries_tx:COUNTER:600:0:U",
+        "DS:stations:GAUGE:600:0:U",
+    ],
+    "station": [
+        "DS:rssi:GAUGE:600:0:U",
+        "DS:noise:GAUGE:600:U:U",
+        "DS:signal:GAUGE:600:U:U",
+        "DS:power:GAUGE:600:0:U",
+        "DS:rate_rx:GAUGE:600:0:U",
+        "DS:rate_tx:GAUGE:600:0:U",
+        "DS:packets_rx:COUNTER:600:0:U",
+        "DS:packets_tx:COUNTER:600:0:U",
+        "DS:bytes_rx:COUNTER:600:0:U",
+        "DS:bytes_tx:COUNTER:600:0:U",
+    ],
+}
+
+
+@contextlib.contextmanager
+def get_mca_data(host):
+    client = paramiko.SSHClient()
+    client.set_missing_host_key_policy(paramiko.MissingHostKeyPolicy())
+    client.connect(host, username=USERNAME, password=PASSWORD)
+    _, stdout, _ = client.exec_command("mca-dump")
+
+    yield json.loads(stdout.read())
+
+    client.close()
+
+
+@contextlib.contextmanager
+def host_folder(host):
+    if not os.path.exists(host):
+        os.mkdir(host)
+
+    os.chdir(host)
+    yield
+    os.chdir(os.path.dirname(os.getcwd()))
+
+
+def rrd_update(kind, name, source, *stats):
+    stats = ":".join(["N"] + list(str(int(source[key])) for key in stats))
+    rrd_name = "{}-{}.rrd".format(kind, name)
+
+    if not os.path.exists(rrd_name):
+        command = ["rrdtool", "create", rrd_name]
+        command.extend(RRD_TEMPLATES[kind])
+        command.extend(RRA_COMMON)
+        subprocess.call(command)
+
+    subprocess.call(("rrdtool", "update", rrd_name, stats))
+
+
+def update_eth(data):
+    rrd_update("interface", "eth0", data, "rx_packets", "tx_packets",
+            "rx_bytes", "tx_bytes", "rx_errors", "tx_errors", "rx_errors",
+            "tx_errors")
+
+def update_network(data):
+    rrd_update("network", "{}_{}".format(data["essid"], data["radio"]), data,
+            "rx_packets", "tx_packets", "rx_bytes", "tx_bytes", "tx_retries",
+            "num_sta")
+
+
+def update_station(data):
+    rrd_update("station", data["mac"], data, "rssi", "noise", "signal",
+            "tx_power", "rx_rate", "tx_rate", "rx_packets", "tx_packets",
+            "rx_bytes", "tx_bytes")
+
+
+while True:
+    for host in HOSTS:
+        print "Updating {}".format(host)
+        with host_folder(host), get_mca_data(host) as data:
+            update_eth(data["if_table"][0])
+
+            for vap in data["vap_table"]:
+                update_network(vap)
+
+                for station in vap["sta_table"]:
+                    update_station(station)
+
+    print "=" * 80
+    time.sleep(300)
diff --git a/parse_dumped_bodies.py b/parse_dumped_bodies.py
index 2bb16a2..4275e68 100644
--- a/parse_dumped_bodies.py
+++ b/parse_dumped_bodies.py
@@ -5,7 +5,7 @@ from cStringIO import StringIO
 from inform import InformSerializer, Cryptor
 
 
-PATH = "/Users/mcrute/Desktop/test"
+PATH = "/Users/mcrute/Desktop/test2"
 
 
 for file in os.listdir(PATH):
diff --git a/requirements.txt b/requirements.txt
index 390e1fe..3c93d5c 100644
--- a/requirements.txt
+++ b/requirements.txt
@@ -1,2 +1,3 @@
 tornado==3.1
 pycrypto==2.6
+paramiko==1.11.1
diff --git a/utils.py b/utils.py
new file mode 100644
index 0000000..2226108
--- /dev/null
+++ b/utils.py
@@ -0,0 +1,16 @@
+def decode_station_band(sta):
+    tx = sta["tx_rate"] / 1000
+    rx = sta["rx_rate"] / 1000
+    is_a = sta.get("is_11a", None)
+    is_n = sta.get("is_11n", False)
+
+    if is_n:
+        return "N"
+
+    if is_a:
+        return "A"
+
+    if not is_n and any((rx > 11, rx > 11)):
+        return "G"
+    else:
+        return "B"
-- 
cgit v1.2.3