Linksys SPA8000 Monitoring Through Zabbix / Business Infinity Group Blog

#!/usr/bin/python
# Get Cisco SPA status for Zabbix.
# codecs импортируется, если происходит отладка скрипта с открытием локального Файла.
#import codecs
import csv
import datetime
import os.path
import re
import sys
import tempfile
import time
import urllib
# Ссылка на интерфейс.
url = 'http:///voice/'
# Путь до файла кэша.
temp = tempfile.gettempdir()
base = temp + '/spa.csv'
# Генератор кэша.
# Если файл кэша не существует или старее 30 секунд, то получаем данные из web-интерфейса.
# Кэш проверяется и создается всегда самым первым, потому что все данные возвращаются
# на основе выборок из файла кэша, то есть напрямую со страницы данные читаются только
# в кэш.
if(not(os.path.exists(base)) or ((int(time.time()) - os.path.getmtime(base)) > 30)):
	# Читаем HTML страницу.
	html = urllib.urlopen(url).read()
	# Отладочная секция - читает файл с диска.
	#f = codecs.open("text.html", 'r', "utf-8")
	#html = f.read()
	#f.close()
	# Нормализуем и парсим HTML.
	# Приводим текст к одной строке.
	html = re.sub(r"\n+", " ", html)
	# Убираем пробелы между тегами.
	html = re.sub(r">\s+<", "><", html)
	# Страница очень длинная - там все вкладки интерфейса. Чтобы уменьшить вероятность
	# выборки не того отрезаем нужный нам кусок страницы.
	html = re.search(r".+?Trunk", html).group(0)
	# Получаем количество линий.
	count  = len(re.findall(r"]+>]+>Line\s(\d+)\sStatus",html))
	# Извлекаем все данные вперемешку. Так как в HTML формат всех полей с данными
	# одинаковый, то просто ищем все совпавшие кусочки данных и считаем их по
	# умолчанию значениями. дальше разберутся.
	data = re.findall(r"([^<:>]+):.+?]+>([^<]*)",html)
	# Создаем CSV файл.
	number = 0
	rows = []
	# Создаем заголовки строк.
	rows.append(['info'])
	count += 1
	for i in range (1, count):
		rows.append(['line' + str(i)])
	count -= 1
	# Заполняем строки. Выбираем из собранных данных все по одному и внимательно
	# присматриваемся. Так как данные лежат в массиве в том порядке, в котором
	# они отображаются на странице, то можем считать, что все значения до определенного
	# относятся к общей информации, а все что дальше, относится к линиям. Так все и устроено
	# первое значение каждой линии - это Hook State. Все что находится до первого такого значения
	# относится к общей информации, все что после - к линиям.
	# Цикл по извлеченным данным.
	for entry in data:
		# Значение, по которому разделяются данные общей информации и линий.
		if(entry[0] == 'Hook State'):
			number += 1
		# Обрабатываем все нужные данные, кроме всяких Call 1 Forward и иже с ними.
		if(not(re.match(r'Call\s\d+\s', entry[0]))):
			value = entry[1]
			# Преобразуем время в соответствующих полях. В Zabbix время уходит в виде unixtime.
			if(((entry[0] == 'Current Time') or (entry[0] == 'Last Registration At')) and (value)): # 1/13/2003 14:03:52
				if(value != '0/0/0 00:00:00'):
					value = int(time.mktime(datetime.datetime.strptime(entry[1], "%m/%d/%Y %H:%M:%S").timetuple()))
				else:
					value = 0
			# Извлекаем количество секунд.
			if((entry[0] == 'Next Registration In') and (value)): # 1263 s
				value = int(entry[1].split()[0])
			# Сохраняем значение в соответствующей строке массива.
			rows[number].extend([value])
	# Сохраняем кэш.
	with open(base, 'w') as csvfile:
		writer = csv.writer(csvfile)
		writer.writerows(rows)
		csvfile.close()
# Ну вот, кэш сохранен, можно теперь его использовать для вывода данных. Проверяем
# наличие параметров. Если они переданы, значит мы хотим чего-то конкретного. 
if(len(sys.argv) > 1):
	# Открываем файл кэша и ищем строку, которую мы запрашиваем первым параметром.
	with open(base, 'rb') as csvfile:
		reader = csv.reader(csvfile)
		for row in reader:
			# TODO: Прерывание цикла, если строка нашлась.
			if(row[0] == sys.argv[1]):
				line = row
		csvfile.close()
	# Проверяем, что запрошенная строка вообще есть в кэше.
	if('line' in locals()):
		# Определяем, что у нас спрашивают вторым параметром, и что вообще возвращать.
		# Блок общей информации.
		if(line[0] == 'info'):
			try:
				print({
					'name': line[1],
					'serial': line[2],
					'software': line[3],
					'hardware': line[4],
					'mac': line[5],
					'cert': line[6],
					'customization': line[7],
					'time': line[8],
					'uptime': line[9],
					'rtp.packets.sent': line[10],
					'rtp.bytes.sent': line[11],
					'rtp.packets.recv': line[12],
					'rtp.bytes.recv': line[13],
					'sip.msg.sent': line[14],
					'sip.bytes.sent': line[15],
					'sip.msg.recv': line[16],
					'sip.bytes.recv': line[17]
				}.get(sys.argv[2]))
			# Если запрошенного поля не нашлось, так и говорим.
			except IndexError as e:
				print('ZBX_UNSUPPORTED')
		# Блок линий.
		else:
			try:
				print({
					'hook.state': line[1],
					'reg.state': line[2],
					'reg.time': line[3],
					'reg.next': line[4],
					'mvi': line[5],
					'callback': line[6],
					'last.called': line[7],
					'last.caller': line[8],
				}.get(sys.argv[2]))
			except IndexError as e:
				print('ZBX_UNSUPPORTED')
	# Если запрашиваемая строка не нашлась в кэше, то тоже возвращаем ошибку.
	# Это позволяет не смущать Zabbix пустым результатом.
	else:
		print('ZBX_UNSUPPORTED')
else:
# Получаем autodiscovery для линий.
	# Выходная строка.
	s = ""
	# Открываем файл кэша и читаем его, формируя выходную строку.
	with open(base, 'rb') as csvfile:
		reader = csv.reader(csvfile)
		for row in reader:
			# Проставляем разделители.
			if(len(s) > 0):
				s = s + ","
			# Формируем JSON строку вручную.
			if(row[0] != 'info'):
				s = s + '{"{#LINE}":"' + str(row[0]) + '"}'
		csvfile.close()
	# Выводим сформированную строку.
	print('{"data":[' + s + ']}')
# Завершаем работу скрипта.
quit()

3.02016-09-09T11:04:05ZШаблоны общие{Template_Cisco_Linksys_SPA:spa[info,uptime].last()}<180SPA перезагружен02Время работы SPA менее 3 минут.0