Разработка системы мониторинга сети для внутренних нужд предприятия ОАО "Хабаровскэнерго"

10. Правила устройства электроустановок ПУЭ. М.:НЦ ЭНАС, 1999.- 80с.

11. Технико-экономическое обоснование дипломных проектов: Учеб. Пособие для втузов. - М.: Высш. шк., 1991.- 176 с.

12. ГОСТ 12-1-004-91 (1999) ССБТ - Пожарная безопасность - Общие требования.

13. Приказ Минфина РФ от 30 марта 2001 г. №26н.

14. Руководящий документ отрасли РД 45.128-2000. Сети и службы передачи данных.

Приложение А

#Текст программы мониторинга коммутаторов ЛВС

# Знаком "#" обозначены комментарии

#! /usr/local/bin/perl

# Подключение модулей для работы с протоколом SNMP и для работы с СУБД

use Net::SNMP;

use DBI;

# Создание соединения по протоколу SNMP

($session, $error) = Net::SNMP->session(

-hostname => shift || '192.168.0.10',

-community => shift || 'public',

-port => shift || 161);

# Подключение к локальной и центральной базе данных

$dbi_user = 'root';

$dbi_password = '';

$dbi_database = 'Sw_01';

$dbi_host = 'localhost';

$dbi_host2 = '192.168.0.1';

$dbi_dsn = "DBI:mysql:database=$dbi_database;host=$dbi_host";

$dbi_dsn2 = "DBI:mysql:database=$dbi_database;host=$dbi_host2";

$dbh = DBI->connect($dbi_dsn, $dbi_user, $dbi_password, { AutoCommit => 1, RaiseError => 1, PrintError => 1 });

$dbh2 = DBI->connect($dbi_dsn2, $dbi_user, $dbi_password, { AutoCommit => 1, RaiseError => 1, PrintError => 1 });

# Запрос на создание таблицы для хранения данных о состоянии коммутатора

($month, $year) = (localtime)[4,5];

$table_name = sprintf ("%02d%02d", $month + 1, $year + 1900);

($sql_create_gtable) = "CREATE TABLE g$table_name (

sID INT(10) UNSIGNED DEFAULT '0' NOT NULL AUTO_INCREMENT,

sDateTime INT(11) UNSIGNED,

sAmount SMALLINT(3) UNSIGNED,

sACPU SMALLINT(3) UNSIGNED,

sFM INT(11) UNSIGNED,

sUptime TEXT,

PRIMARY KEY (sID));";

# Запрос на создание таблицы для хранения данных об интерфейсах коммутатора

($sql_create_iftable) = "CREATE TABLE if$table_name (

sID INT(10) UNSIGNED DEFAULT '0' NOT NULL AUTO_INCREMENT,

sDateTime INT(11) UNSIGNED,

sDescr TEXT,

sSpeedPort INT(10) UNSIGNED,

sInOct INT(10) UNSIGNED,

sOutOct INT(10) UNSIGNED,

sOperPort TINYINT(1) UNSIGNED,

sAdminPort TINYINT(1) UNSIGNED,

sInErrors INT(6) UNSIGNED,

sOutErrors INT(6) UNSIGNED,

PRIMARY KEY (sID));";

# Если таблиц с таким названием (номер текущего месяца) нет, тогда их создать

$sth = $dbh->prepare("show tables from $dbi_database like 'g$table_name';");

$sth->execute() or die $dbh->errstr;

$ex = $sth->fetchrow_array();

if($ex ne "g$table_name")

{$dbh->do($sql_create_gtable);

$sth->execute() or die $dbh->errstr;};

$sth = $dbh->prepare("show tables from $dbi_database like 'if$table_name';");

$sth->execute() or die $dbh->errstr;

$ex = $sth->fetchrow_array();

if($ex ne "if$table_name")

{$dbh->do($sql_create_iftable);

$sth->execute() or die $dbh->errstr;};

$sth = $dbh2->prepare("show tables from $dbi_database like 'g$table_name';");

$sth->execute() or die $dbh2->errstr;

$ex = $sth->fetchrow_array();

if($ex ne "g$table_name")

{$dbh2->do($sql_create_gtable);

$sth->execute() or die $dbh2->errstr;};

$sth = $dbh2->prepare("show tables from $dbi_database like 'if$table_name';");

$sth->execute() or die $dbh2->errstr;

$ex = $sth->fetchrow_array();

if($ex ne "if$table_name")

{$dbh2->do($sql_create_iftable);

$sth->execute() or die $dbh2->errstr;};

$datetime = time();

# Получение данных о состоянии коммутатора и запись из в базу данных

$AmountPort = '.1.3.6.1.2.1.2.1.0'; # Количество интерфейсов

$ResultAmount = $session->get_request($AmountPort);

$AverageCPULoad = '.1.3.6.1.4.1.9.2.1.58.0'; # Загрузка центрального процессора

$ResultACL = $session->get_request($AverageCPULoad);

$FreeMemory = '.1.3.6.1.4.1.9.2.1.8.0'; # Объем свободной памяти

$ResultFM = $session->get_request($FreeMemory);

$Uptime = '.1.3.6.1.2.1.1.3.0'; # Время наработки на отказ

$ResultUptime = $session->get_request($Uptime);

$dbh->do("INSERT INTO g$table_name (sDateTime, sAmount, sACPU, sFM, sUptimec) VALUES ('$datetime', '$ResultAmount->{$AmountPort}', '$ResultACL->{$AverageCPULoad}', '$ResultFM->{$FreeMemory}', '$ResultUptime->{$Uptime}')");

$dbh2->do("INSERT INTO g$table_name (sDateTime, sAmount, sACPU, sFM, sUptimec) VALUES ('$datetime', '$ResultAmount->{$AmountPort}', '$ResultACL->{$AverageCPULoad}', '$ResultFM->{$FreeMemory}', '$ResultUptime->{$Uptime}')");

# Считывание из файла данных о предыдущем состоянии статуса интерфейсов коммутатора

open (OLDSTATE, "state.old");

$previous = <OLDSTATE>;

close(OLDSTATE);

# Цикл по количеству интерфейсов

for ($i = 1; $i <=($ResultAmount->{$AmountPort}); $i++)

# Получение данных об интерфейсах

{$DescrPort = ".1.3.6.1.2.1.2.2.1.2.$i"; # Описание интерфейса

$SpeedPort = ".1.3.6.1.2.1.2.2.1.5.$i"; # Скорость интерфейса

$OperPort = ".1.3.6.1.2.1.2.2.1.8.$i"; # Оперативное состояние интерфейса

$AdminPort = ".1.3.6.1.2.1.2.2.1.7.$i"; # Административное состояние интерфейса

$InOctets = ".1.3.6.1.2.1.2.2.1.10.$i"; # Количество входящих байт (через интерфейс)

$OutOctets = ".1.3.6.1.2.1.2.2.1.16.$i"; # Количество исходящих байт

$ifInErrors = ".1.3.6.1.2.1.2.2.1.14.$i"; # Количество входящих байт с ошибками

$ifOutErrors = ".1.3.6.1.2.1.2.2.1.20.$i"; # Количество исходящих байт с ошибками

$ResultDescr = $session->get_request($DescrPort);

$ResultSpeed = $session->get_request($SpeedPort);

$ResultOper = $session->get_request($OperPort);

$ResultAdmin = $session->get_request($AdminPort);

$ResultInOctets = $session->get_request($InOctets);

$ResultOutOctets = $session->get_request($OutOctets);

$ResultInErrors = $session->get_request($ifInErrors);

$ResultOutErrors = $session->get_request($ifOutErrors);

# Сравнение предыдущего оперативного состояния интерфейса с поступившим

# Если состояние изменилось - оправляется сообщение администратору

$state_c = $ResultOper->{$OperPort};

$state_o = substr($previous, $i, 1);

$current .= $state_c;

if($state_c ne $state_o)

{open (SENDMAIL, "|/usr/sbin/sendmail -oi -t -odq");

print (SENDMAIL "To: 79022270899@sms.dti.ru Subject: SNMP Alert! Interface $ResultDescr of Sw_01 changed status. EOF");

close (SENDMAIL);}

# Запись в базу данных информации об интерфейсах

$dbh->do("INSERT INTO if$table_name (sDateTime, sDescr, sSpeedPort, sInOct, sOutOct, sOperPort, sAdminPort, sInErrors, sOutErrors) VALUES ('$datetime', '$ResultDescr->{$DescrPort}', '$ResultSpeed->{$SpeedPort}', '$ResultInOctets->{$InOctets}', '$ResultOutOctets->{$OutOctets}', '$ResultOper->{$OperPort}', '$ResultAdmin->{$AdminPort}', '$ResultInErrors->{$ifInErrors}', '$ResultOutErrors->{$ifOutErrors}')");

$dbh2->do("INSERT INTO if$table_name (sDateTime, sDescr, sSpeedPort, sInOct, sOutOct, sOperPort, sAdminPort, sInErrors, sOutErrors) VALUES ('$datetime', '$ResultDescr->{$DescrPort}', '$ResultSpeed->{$SpeedPort}', '$ResultInOctets->{$InOctets}', '$ResultOutOctets->{$OutOctets}', '$ResultOper->{$OperPort}', '$ResultAdmin->{$AdminPort}', '$ResultInErrors->{$ifInErrors}', '$ResultOutErrors->{$ifOutErrors}')");

};

# Запись информации в файл о последних полученных состояниях интерфейсов

open (OLDSTATE, ">state.old");

print (OLDSTATE "$current\n");

close(OLDSTATE);

$session->close;

$dbh->disconnect();

Приложение Б

# Текст программы сбора тарификационной информации с УАТС Hicom

#!/usr/bin/perl -w

# Подключение модуля для работы с СУБД

use DBI;

# Выбор модуля для работы с com-портом в зависимости от операционной системы

BEGIN {

$OS_win = ($^O eq "MSWin32") ? 1 : 0;

if ($OS_win) {

eval "use Win32::SerialPort";}

else {

eval "use Device::SerialPort";}}

if ($OS_win) {

$port = 'COM0';

$ob = Win32::SerialPort->new ($port);}

else {

$port = '/dev/ttys0';

$ob = Device::SerialPort->new ($port);}

die "Can't open serial port $port: $^E\n" unless ($ob);

# Установление параметров работы с com-портом

$ob->baudrate(38400); # Скорость передачи данных через порт

$ob->parity("none"); # Наличие бита четности

$ob->databits(8); # Биты данных

$ob->stopbits(1); # Количество стоповых бит

$ob->handshake('none'); # Управление потоком

$ob->write_settings; # Применение настроек

# Подлючение к локальной и центральной базам данных

$dbi_user = 'root';

$dbi_password = '';

$dbi_database = 'ATS_01';

$dbi_host = 'localhost';

# Параметры для подлючения к локальной базе данных

$dbi_dsn = "DBI:mysql:database=$dbi_database;host=$dbi_host";

$dbi_host2 = '192.168.0.1';

# Параметры для подлючения к центральной базе данных

$dbi_dsn2 = "DBI:mysql:database=$dbi_database;host=$dbi_host2";

$dbh = DBI->connect($dbi_dsn, $dbi_user, $dbi_password, {AutoCommit => 1, RaiseError => 1, PrintError => 1 });

$dbh2 = DBI->connect($dbi_dsn2, $dbi_user, $dbi_password, {AutoCommit => 1, RaiseError => 1, PrintError => 1 });

# Запрос на создание таблицы

($month, $year) = (localtime)[4,5];

$table_name = sprintf ("s%02d%02d", $month + 1, $year + 1900);

($sql_create_table) = "CREATE TABLE $table_name (

sID INT(10) UNSIGNED DEFAULT '0' NOT NULL AUTO_INCREMENT,

sDateCall DATE DEFAULT '0000-00-00' NOT NULL,

sTimeCall TIME DEFAULT '00:00:00' NOT NULL,

sLine SMALLINT(3) UNSIGNED DEFAULT '0' NOT NULL,

sStn VARCHAR(8),

sTimeTalk TIME DEFAULT '00:00:00' NOT NULL,

sDestno VARCHAR(16),

sTimeTalkSec INT(10) UNSIGNED,

PRIMARY KEY (sID));";

# Если таблица с таким названием (название - текущий месяц) не существует, то ее создать

# в локальной и центральной базах данных

$sth = $dbh->prepare("show tables from $dbi_database like '$table_name';");

$sth->execute() or die $dbh->errstr;

$ex = "";

$ex = $sth->fetchrow_array();

if($ex ne $table_name) {

$dbh->do($sql_create_table);

$sth->execute() or die $dbh->errstr;};

$sth=$dbh2->prepare("show tables from $dbi_database like '$table_name';");

$sth->execute() or die $dbh2->errstr;

$ex="";

$ex=$sth->fetchrow_array();

if($ex ne $table_name) {

$dbh2->do($sql_create_table);

$sth->execute() or die $dbh2->errstr;};

$timestart = time();

$timeout = 2;

$result = "";

# Опрос com-порта в цикле (осуществляется до истечения тайм-аута)

while((time() - $timestart) < $timeout) {

# Чтение одного байта информации из com-порта ($count - признак того, что данные

# из com-порта поступили, $active - данные, считанные из порта)

($count, $active) = $ob->read(1);

# Если данные поступили, то дописать их в переменную-накопитель и сбросить счетчик

# времени для тайм-аута

if($count)

{ $result .= $active;

$timestart = time();}

# Обработка информации

if ($result =~ m/\r/)

# Отбросить символ "$" из строки

{if ($result =~ m/\$(.*)\+/)

# Разбить строку на составляющие и записать их в переменные

{($datetime, $sline, $sstn, $stimetalk, $sdestno) = split(/\s*\+\s*/, $result);

# Выделить дату и время

($date, $time) = $datetime =~ m/\$(\d{6})(\d{6})/;

# Перевести время разговора в секунды

($hour, $min, $sec) = $stimetalk =~ m/(\d{2})(\d{2})(\d{2})/;

$stimetalksec = ($hour * 3600) + ($min * 60) + $sec;

# Записать полученные данные в локальную и центральную базу данных

$dbh->do("INSERT INTO $table_name (sDateCall, sTimeCall, sLine, sStn, sTimeTalk, sDestno, sTimeTalkSec) VALUES ('$date', '$time', '$sline', '$sstn', '$stimetalk', '$sdestno', '$stimetalksec')");

$dbh2->do("INSERT INTO $table_name (sDateCall, sTimeCall, sLine, sStn, sTimeTalk, sDestno, sTimeTalkSec) VALUES ('$date', '$time', '$sline', '$sstn', '$stimetalk', '$sdestno', '$stimetalksec')");}

$result = "";}}

$dbh->disconnect();

$dbh2->disconnect();

undef $ob;

Приложение В

# Текст программы сбора тарификационной информации с УАТС NEAX

#!/usr/bin/perl -w

# Подключение модуля для работы с СУБД

use DBI;

BEGIN {

$OS_win = ($^O eq "MSWin32") ? 1 : 0;

if ($OS_win) {

eval "use Win32::SerialPort";}

else {

eval "use Device::SerialPort"}}

if ($OS_win) {

$port = 'COM2';

$ob = Win32::SerialPort->new ($port);

}

else {

$port = '/dev/ttyS0';

$ob = Device::SerialPort->new ($port);

} die "Can't open serial port $port: $^E\n" unless ($ob);

# Установление параметров работы с com-портом

$ob->baudrate(38400); # Скорость передачи данных через порт

$ob->parity("none"); # Наличие бита четности

$ob->databits(8); # Биты данных

$ob->stopbits(1); # Количество стоповых бит

$ob->handshake('none'); # Управление потоком

$ob->write_settings; # Применение настроек

# Подлючение к локальной и центральной базам данных

$dbi_user = 'root';

$dbi_password = '';

$dbi_database = 'nec';

$dbi_host = 'localhost';

$dbi_dsn = "DBI:mysql:database=$dbi_database;host=$dbi_host";

$dbi_host2 = '192.168.1.1';

$dbi_dsn2 = "DBI:mysql:database=$dbi_database;host=$dbi_host2";

$dbh = DBI->connect($dbi_dsn, $dbi_user, $dbi_password, { AutoCommit => 1, RaiseError => 1, PrintError => 1 });

$dbh2 = DBI->connect($dbi_dsn2, $dbi_user, $dbi_password, { AutoCommit => 1, RaiseError => 1, PrintError => 1 });

($month, $year) = (localtime)[4,5];

$table_name = sprintf ("s%02d%02d", $month + 1, $year + 1900);

# Запрос на создание таблицы

($sql_create_table) = "CREATE TABLE $table_name (sID INT(10) UNSIGNED DEFAULT '0' NOT NULL AUTO_INCREMENT,

nums VARCHAR(6),

numd VARCHAR(24),

starttime VARCHAR(10),

endtime VARCHAR(10),

timetalksec int(10) UNSIGNED,

PRIMARY KEY (sID));";

# Если таблица с таким названием (название - текущий месяц) не существует, то ее создать

# в локальной и центральной базах данных

$sth = $dbh->prepare("show tables from $dbi_database like '$table_name';");

$sth->execute() or die $dbh->errstr;

$ex = "";

$ex = $sth->fetchrow_array();

if($ex ne $table_name) {

$dbh->do($sql_create_table);

$sth->execute() or die $dbh->errstr;};

$sth=$dbh2->prepare("show tables from $dbi_database like '$table_name';");

$sth->execute() or die $dbh2->errstr;

$ex="";

$ex=$sth->fetchrow_array();

if($ex ne $table_name) {

$dbh2->do($sql_create_table);

$sth->execute() or die $dbh2->errstr;};

$timestart = time();

$timeout = 2;

$result = "";

# Опрос com-порта в цикле (осуществляется до истечения тайм-аута)

while((time() - $timestart) < $timeout)

{

# Чтение одного байта информации из com-порта ($count - признак того, что данные

# из com-порта поступили, $active - данные, считанные из порта)

($count, $active) = $ob->read(1);

# Если данные поступили, то дописать их в переменную-накопитель и сбросить счетчик

# времени для тайм-аута

if($count)

{

$result .= $active;

$timestart = time();}

# Обработка информации

if ($result =~ m/B0!K.{64}/) # Если набралась полная строка данных

{

$ssrcno = substr($result, 12, 6); # Выделение номера вызывающего абонента

$sdestno = substr($result, 47, 26); # Выделение номера вызываемого абонента

$sstarttime = substr($result, 20, 10); # Выделение времени начала разговора

$sendtime = substr($result, 30, 10); # Выделение времени окончания разговора

# Расчет продолжительности разговора в секундах

$stimetalksec = ((substr($result, 32, 2) * 3600) + (substr($result, 34, 2) * 60) + substr($result, 36, 2)) - ((substr($result, 22, 2) * 3600) + (substr($result, 24, 2) * 60) + substr($result, 26, 2));

# Запись значений в базы данных

$dbh->do("INSERT INTO $table_name (nums, numd, starttime, endtime, timetalksec) VALUES ('$ssrcno', '$sdestno', '$sstarttime', '$sendtime', '$stimetalksec')");

$dbh2->do("INSERT INTO $table_name (nums, numd, starttime, endtime, timetalksec) VALUES ('$ssrcno', '$sdestno', '$sstarttime', '$sendtime', '$stimetalksec')");

$result = "";}}

$dbh->disconnect();

$dbh2->disconnect();

undef $ob;

Приложение Г

# Текст программы для построения графиков нагрузки на направление

#!/usr/bin/perl

# Подключение модулей для работы с СУБД и для построения графиков

use DBI;

use GD::Graph::lines;

# Инициализация переменных, в переменной $dsn записываются параметры

# подключенения к базе данных: тип СУБД - MySQL, название базы данных - ATS_01,

# адрес подключения к базе данных - localhost

my ($dsn)="DBI:mysql:ATS_01:localhost";

my ($dbh,$sth);

my @data;

$count="0";

$start=1; # Первый день рассматриваемого периода

$finish=7; # Последний день рассматриваемого периода

$month='2003-03'; # Рассматриваемый месяц

$Title='s0305'; # Название таблицы в базе данных

$Lines='800'; # Номер направления

$interval=30;

$Nagruzka=25; # Пороговое значение нагрузки

# Подключение к базе данных

$dbh=DBI->connect($dsn,"","",{RaiseError=>1});

# Проверка наличия в базе данных временных таблиц end_01 и end_02, если таблицы

# существуют, то они удаляются

$sth=$dbh->prepare("show tables from ATS_01 like 'end_01';");

$sth->execute() or die $dbh->errstr;

$ex="";

$ex=$sth->fetchrow_array();

if($ex eq "end_01") {

$sth=$dbh->prepare("drop table end_01;");

$sth->execute() or die $dbh->errstr;};

$sth=$dbh->prepare("show tables from ATS_01 like 'end_02';");

$sth->execute() or die $dbh->errstr;

$ex="";

$ex=$sth->fetchrow_array();

if($ex eq "end_02") {

$sth=$dbh->prepare("drop table end_02;");

$sth->execute() or die $dbh->errstr;};

# Цикл по каждому дню рассматриваемого периода

for($j=$start;$j<=$finish;$j=$j+1){

# Формирование даты

if ($j<10) {$date=($month)"-0".($j)}

else {$date=($month)"-".($j)};

# Создание временной таблицы для записей о звонках за определенный день

($sql_day)="CREATE TABLE end_01 SELECT * FROM $Title WHERE

sDateCall BETWEEN ' $date ' AND ' $date ' ";

$sth=$dbh->prepare($sql_day);

$sth->execute() or die $dbh->errstr;

# Создание временной таблицы для записей о звонках в определенном направлении

# В этой таблицы значения начала и конца разговора переведены в секунды

# относительно начала суток

($sql_day)="CREATE TABLE end_02 SELECT sLine, (TIME_TO_SEC(sTimeCall))

AS 'sTimeCallSec', (TIME_TO_SEC (sTimeCall) + TIME_TO_SEC (sTimeTalk)) AS

'sTimeEndSec' FROM end_01";

$sth=$dbh->prepare($sql_day);

$sth->execute() or die $dbh->errstr;

# Создание нового объекта "График"

my $mygraph=GD::Graph::lines->new(1000,500);

$mygraph->set(

x_label =>'Time',

y_label =>'Count',

title =>'800') or warn $mygraph->error;

# Цикл, в котором рассматриваются текущие сутки по заданному интервалу в

# секундах

for ($i="0";$i<86400;$i=$i+$interval){

# Запрос на определение количества записей в таблице end_02, которые

# попадают в рассматриваемый на данной итерации цикла интервал

($sql_count800)="SELECT COUNT(*) FROM end_02 WHERE

(($i>=sTimeCallSec) AND ($i<=sTimeEndSec))";

$sth=$dbh->prepare($sql_count300);

$sth->execute() or die $dbh->errstr;

$res=$sth->fetchrow_array();

$count=$res;

# Формирование данных для построения графика

$data[0][$i]="$i";

$data[1][$i]=int $count;

# Формирование времени в формате "часы-минуты-секунды"

$h=int($i/3600);

$hour=$h;

if ($h<10) {$hour='0'.$h};

$m=int(($i%3600)/60);

$min=$m;

if ($m<10) {$min='0'.$m};

$s=int(($i%3600)%60);

$sec=$s;

if ($s<10) {$sec='0'.$s};

# Если количество вызовов за данный интервал превышает пороговое

# значение, то об этом выводится сообщение

if ($count>=$Nagruzka) {print $Lines,"\t", $hour ,":",$min,":",$sec,"-",$count,"\n"};}

# Формирование графика и сохранение его в файл

my $myimage=$mygraph->plot(\@data) or die $mygraph->error;

open (PICTURE,">c:\\picture_800_$j.png") or die("Cannot open file for writing");

binmode PICTURE;

print PICTURE $myimage->png;

close (PICTURE);

print "\n", "\n";

# Удаление временных таблиц

($sql_drop)="DROP TABLE end_01";

$sth=$dbh->prepare($sql_drop);

$sth->execute() or die $dbh->errstr;

($sql_drop)="DROP TABLE end_02";

$sth=$dbh->prepare($sql_drop);

$sth->execute() or die $dbh->errstr;}

# Отключение от базы данных

$dbh->disconnect(); print "Finish"; exit(0);

Размещено на Allbest.ru