Архивы snmp

Python: получение по протоколу snmp данных о разрыве на Ethernet соединении.

11.01.2023 Павел Грибов Linux

Применимо в основном для управляемых свичей Dlink/Orion

Принципиальный код:

def get_cable_port_status(host: str, user_port: int, snmp_ro_comm: str = 'X-Files') -> List:
    """
    Метод проверки статуса порта, витой пары и длины пар
    возвращает список словарей типа {'command_name': 'CABLE_STATUS', 'oid': '1.3.6.1.4.1.171.12.58.1.1.1.4.4', 'result': 8}
    """
    SET_COMMAND = f'1.3.6.1.4.1.171.12.58.1.1.1.12.{user_port}'  # команда для получения статуса порта
    CABLE_STATUS_COMMAND = f'1.3.6.1.4.1.171.12.58.1.1.1.12.{user_port}'  # получение статуса кабеля

    status_dict = [{"command_name": "CABLE_STATUS", "oid": f'1.3.6.1.4.1.171.12.58.1.1.1.4.{user_port}'},
                   # статус кабеля 8 кабель не воткнут, 1 с одной стороны в воздухе
                   {"command_name": "LINK_STATUS", "oid": f'1.3.6.1.4.1.171.12.58.1.1.1.3.{user_port}'},
                   # статус порта 1 - ок, иначе нет
                   {"command_name": "PAIR_1", "oid": f'1.3.6.1.4.1.171.12.58.1.1.1.8.{user_port}'},
                   # длина 1 пары
                   {"command_name": "PAIR_2", "oid": f'1.3.6.1.4.1.171.12.58.1.1.1.9.{user_port}'},
                   # длина 2 пары
                   {"command_name": "PAIR_3", "oid": f'1.3.6.1.4.1.171.12.58.1.1.1.10.{user_port}'},
                   # длина 3 пары
                   {"command_name": "PAIR_4", "oid": f'1.3.6.1.4.1.171.12.58.1.1.1.11.{user_port}'},
                   # длина 4 пары
                   {"command_name": "PAIR_1_STATUS", "oid": f'1.3.6.1.4.1.171.12.58.1.1.1.4.{user_port}'},
                   # статус 1 пары
                   {"command_name": "PAIR_2_STATUS", "oid": f'1.3.6.1.4.1.171.12.58.1.1.1.5.{user_port}'},
                   # статус 2 пары
                   {"command_name": "PAIR_3_STATUS", "oid": f'1.3.6.1.4.1.171.12.58.1.1.1.6.{user_port}'},
                   # статус 3 пары
                   {"command_name": "PAIR_4_STATUS", "oid": f'1.3.6.1.4.1.171.12.58.1.1.1.7.{user_port}'},
                   # статус 4 пары
                   ]

    new_value = Integer(1)
    type = ObjectType(ObjectIdentity(SET_COMMAND), new_value)
    g = setCmd(SnmpEngine(), CommunityData(snmp_ro_comm), UdpTransportTarget((host, 161)), ContextData(), type,
               lookupMib=False)
    next(g)

    auth = cmdgen.CommunityData(snmp_ro_comm)
    cmdGen = cmdgen.CommandGenerator()
    errorIndication, errorStatus, errorIndex, varBinds = cmdGen.getCmd(
        auth,
        cmdgen.UdpTransportTarget((host, 161)),
        *[cmdgen.MibVariable(oid) for oid in [oid["oid"] for oid in status_dict]],
        lookupMib=False,
    )

    if errorIndication:
        return False

    for oid, val in varBinds:
        for result in status_dict:
            if str(result["oid"]) == str(oid):
                result["result"] = int(val)

    return status_dict

def get_cable_port_status(host: str, user_port: int, snmp_ro_comm: str = 'X-Files') -> List:

"""

Метод проверки статуса порта, витой пары и длины пар

возвращает список словарей типа {'command_name': 'CABLE_STATUS', 'oid': '1.3.6.1.4.1.171.12.58.1.1.1.4.4', 'result': 8}

"""

SET_COMMAND = f'1.3.6.1.4.1.171.12.58.1.1.1.12.{user_port}' # команда для получения статуса порта

CABLE_STATUS_COMMAND = f'1.3.6.1.4.1.171.12.58.1.1.1.12.{user_port}' # получение статуса кабеля

status_dict = [{"command_name": "CABLE_STATUS", "oid": f'1.3.6.1.4.1.171.12.58.1.1.1.4.{user_port}'},

# статус кабеля 8 кабель не воткнут, 1 с одной стороны в воздухе

{"command_name": "LINK_STATUS", "oid": f'1.3.6.1.4.1.171.12.58.1.1.1.3.{user_port}'},

# статус порта 1 - ок, иначе нет

{"command_name": "PAIR_1", "oid": f'1.3.6.1.4.1.171.12.58.1.1.1.8.{user_port}'},

# длина 1 пары

{"command_name": "PAIR_2", "oid": f'1.3.6.1.4.1.171.12.58.1.1.1.9.{user_port}'},

# длина 2 пары

{"command_name": "PAIR_3", "oid": f'1.3.6.1.4.1.171.12.58.1.1.1.10.{user_port}'},

# длина 3 пары

{"command_name": "PAIR_4", "oid": f'1.3.6.1.4.1.171.12.58.1.1.1.11.{user_port}'},

# длина 4 пары

{"command_name": "PAIR_1_STATUS", "oid": f'1.3.6.1.4.1.171.12.58.1.1.1.4.{user_port}'},

# статус 1 пары

{"command_name": "PAIR_2_STATUS", "oid": f'1.3.6.1.4.1.171.12.58.1.1.1.5.{user_port}'},

# статус 2 пары

{"command_name": "PAIR_3_STATUS", "oid": f'1.3.6.1.4.1.171.12.58.1.1.1.6.{user_port}'},

# статус 3 пары

{"command_name": "PAIR_4_STATUS", "oid": f'1.3.6.1.4.1.171.12.58.1.1.1.7.{user_port}'},

# статус 4 пары

]

new_value = Integer(1)

type = ObjectType(ObjectIdentity(SET_COMMAND), new_value)

g = setCmd(SnmpEngine(), CommunityData(snmp_ro_comm), UdpTransportTarget((host, 161)), ContextData(), type,

lookupMib=False)

next(g)

auth = cmdgen.CommunityData(snmp_ro_comm)

cmdGen = cmdgen.CommandGenerator()

errorIndication, errorStatus, errorIndex, varBinds = cmdGen.getCmd(

auth,

cmdgen.UdpTransportTarget((host, 161)),

*[cmdgen.MibVariable(oid) for oid in [oid["oid"] for oid in status_dict]],

lookupMib=False,

)

if errorIndication:

return False

for oid, val in varBinds:

for result in status_dict:

if str(result["oid"]) == str(oid):

result["result"] = int(val)

return status_dict

Вывод в консоли будет вида:

[{'command_name': 'CABLE_STATUS', 'oid': '1.3.6.1.4.1.171.12.58.1.1.1.4.4', 'result': 8}, {'command_name': 'LINK_STATUS', 'oid': '1.3.6.1.4.1.171.12.58.1.1.1.3.4', 'result': 1}, {'command_name': 'PAIR_1', 'oid': '1.3.6.1.4.1.171.12.58.1.1.1.8.4', 'result': 0}, {'command_name': 'PAIR_2', 'oid': '1.3.6.1.4.1.171.12.58.1.1.1.9.4', 'result': 46}, {'command_name': 'PAIR_3', 'oid': '1.3.6.1.4.1.171.12.58.1.1.1.10.4', 'result': 46}, {'command_name': 'PAIR_4', 'oid': '1.3.6.1.4.1.171.12.58.1.1.1.11.4', 'result': 0}, {'command_name': 'PAIR_1_STATUS', 'oid': '1.3.6.1.4.1.171.12.58.1.1.1.4.4', 'result': 8}, {'command_name': 'PAIR_2_STATUS', 'oid': '1.3.6.1.4.1.171.12.58.1.1.1.5.4', 'result': 0}, {'command_name': 'PAIR_3_STATUS', 'oid': '1.3.6.1.4.1.171.12.58.1.1.1.6.4', 'result': 0}, {'command_name': 'PAIR_4_STATUS', 'oid': '1.3.6.1.4.1.171.12.58.1.1.1.7.4', 'result': 8}]

[{'command_name': 'CABLE_STATUS', 'oid': '1.3.6.1.4.1.171.12.58.1.1.1.4.4', 'result': 8}, {'command_name': 'LINK_STATUS', 'oid': '1.3.6.1.4.1.171.12.58.1.1.1.3.4', 'result': 1}, {'command_name': 'PAIR_1', 'oid': '1.3.6.1.4.1.171.12.58.1.1.1.8.4', 'result': 0}, {'command_name': 'PAIR_2', 'oid': '1.3.6.1.4.1.171.12.58.1.1.1.9.4', 'result': 46}, {'command_name': 'PAIR_3', 'oid': '1.3.6.1.4.1.171.12.58.1.1.1.10.4', 'result': 46}, {'command_name': 'PAIR_4', 'oid': '1.3.6.1.4.1.171.12.58.1.1.1.11.4', 'result': 0}, {'command_name': 'PAIR_1_STATUS', 'oid': '1.3.6.1.4.1.171.12.58.1.1.1.4.4', 'result': 8}, {'command_name': 'PAIR_2_STATUS', 'oid': '1.3.6.1.4.1.171.12.58.1.1.1.5.4', 'result': 0}, {'command_name': 'PAIR_3_STATUS', 'oid': '1.3.6.1.4.1.171.12.58.1.1.1.6.4', 'result': 0}, {'command_name': 'PAIR_4_STATUS', 'oid': '1.3.6.1.4.1.171.12.58.1.1.1.7.4', 'result': 8}]

Код не мой, предоставлен postcoder для «истории» 😉

Оставить комментарий dlink, orion, snmp

Многопоточный опрос уровней абонентов станций GPON OLT

17.10.2018 Павел Грибов Python

На выходе скрипт обновляет таблицу в MySQL, уровнем сигнала:

#!/usr/local/bin/python
# coding=utf-8

import mysql.connector
from mysql.connector import Error
import config    
import func
import socket
import re
from tendo import singleton
from pysnmp.hlapi import *
import threading
import time 


vr="1.0"
info="Сей дивный скрипт лезет snmp запросом на свичи olt/pon и опрашивает уровни"
copyleft="(с) 2018 by Pavel Gribov, http://грибовы.рф";
#выводим имя ПК и версию скрипта                
hostname = socket.gethostname()
print "Server: ",hostname
print "Version: ",vr
print "info: ",info
print "Copyright: ",copyleft

workcount=50; #количество потоков для опроса


def GetArrayLevels(ip,comm,oid):
 res=None
 errorIndication, errorStatus, errorIndex, varBinds = next(
    getCmd(SnmpEngine(),
           CommunityData(comm),
           UdpTransportTarget(
               (ip, 161), timeout=2.0, retries=0
           ),
           ContextData(),
           ObjectType(ObjectIdentity(oid)))
 )  	     
 if errorIndication:
    print("Ошибка:",ip,comm,oid,errorIndication)
    return res
 elif errorStatus:
    print('%s at %s' % (errorStatus.prettyPrint(),
                        errorIndex and varBinds[int(errorIndex) - 1][0] or '?'))
    return res			
 else:
    for varBind in varBinds:     
     if varBind[1]<0: res=varBind[1]
 return res

def worker(ip,community,ind,idr): 
    rz=GetArrayLevels(ip,community,".1.3.6.1.4.1.3320.101.10.5.1.5."+str(ind))
    try:
        conn2 = mysql.connector.connect(host=config.noc_host,database=config.noc_base,user=config.noc_user,password=config.noc_pass)
        #if conn2.is_connected(): func.putlog('--cоединение с БД '+config.noc_base+' установлено')
    except Error as e:
        print("Ошибка: ",e);
        exit(0);    
    finally:
        if rz!=None: 
                print ("Level:",rz);
                sql="update oltlevels set level=%s,lastmod=now() where id=%s";
                print ("update oltlevels set level="+str(rz)+" where id="+str(idr))
                ccr = conn2.cursor(dictionary=True,buffered=True)
                ccr.execute(sql,[str(rz),idr]);  
                conn2.commit();
    conn2=None
func.putlog("-скрипт стартовал");
func.putlog("--проверяю, а не запущены ли мы уже?");
try:
 me = singleton.SingleInstance() 
except:
    func.putlog("--мы уже запущены!");    
    exit(1)
func.putlog("--Ок. Одна копия, работаем дальше");    
func.putlog("--соединяемся с noc");
try:
    conn = mysql.connector.connect(host=config.noc_host,database=config.noc_base,user=config.noc_user,password=config.noc_pass)
    if conn.is_connected(): func.putlog('--cоединение с БД '+config.noc_base+' установлено')
except Error as e:
    print("Ошибка: ",e);
    exit(0);    
finally:
    func.putlog("---делаем выборку устройств для опроса");
    sql="select * from oltlevels order by rand()";
    cursor = conn.cursor(dictionary=True,buffered=True)
    cursor.execute(sql);
    row = cursor.fetchone()	    
    while row is not None:      
        ip=row["ip"]
        community=row["community"]
        idr=row["id"]
        ind=row["ind"]
        func.putlog("----опрашиваем "+str(ip)+" ind="+str(ind)+",id="+str(idr));                
        thread = threading.Thread(target=worker, args=(ip,community,ind,idr,)).start()	
        while threading.active_count() >workcount:
         time.sleep(1)

        row = cursor.fetchone()	 
        
    while threading.active_count() >workcount:
         time.sleep(1)    
    func.putlog("---закончили");

100

101

102

103

104

#!/usr/local/bin/python

# coding=utf-8

import mysql.connector

from mysql.connector import Error

import config

import func

import socket

import re

from tendo import singleton

from pysnmp.hlapi import *

import threading

import time

vr="1.0"

info="Сей дивный скрипт лезет snmp запросом на свичи olt/pon и опрашивает уровни"

copyleft="(с) 2018 by Pavel Gribov, http://грибовы.рф";

#выводим имя ПК и версию скрипта

hostname = socket.gethostname()

print "Server: ",hostname

print "Version: ",vr

print "info: ",info

print "Copyright: ",copyleft

workcount=50; #количество потоков для опроса

def GetArrayLevels(ip,comm,oid):

res=None

errorIndication, errorStatus, errorIndex, varBinds = next(

getCmd(SnmpEngine(),

CommunityData(comm),

UdpTransportTarget(

(ip, 161), timeout=2.0, retries=0

ContextData(),

ObjectType(ObjectIdentity(oid)))

)

if errorIndication:

print("Ошибка:",ip,comm,oid,errorIndication)

return res

elif errorStatus:

print('%s at %s' % (errorStatus.prettyPrint(),

errorIndex and varBinds[int(errorIndex) - 1][0] or '?'))

return res

else:

for varBind in varBinds:

if varBind[1]<0: res=varBind[1]

return res

def worker(ip,community,ind,idr):

rz=GetArrayLevels(ip,community,".1.3.6.1.4.1.3320.101.10.5.1.5."+str(ind))

try:

conn2 = mysql.connector.connect(host=config.noc_host,database=config.noc_base,user=config.noc_user,password=config.noc_pass)

#if conn2.is_connected(): func.putlog('--cоединение с БД '+config.noc_base+' установлено')

except Error as e:

print("Ошибка: ",e);

exit(0);

finally:

if rz!=None:

print ("Level:",rz);

sql="update oltlevels set level=%s,lastmod=now() where id=%s";

print ("update oltlevels set level="+str(rz)+" where id="+str(idr))

ccr = conn2.cursor(dictionary=True,buffered=True)

ccr.execute(sql,[str(rz),idr]);

conn2.commit();

conn2=None

func.putlog("-скрипт стартовал");

func.putlog("--проверяю, а не запущены ли мы уже?");

try:

me = singleton.SingleInstance()

except:

func.putlog("--мы уже запущены!");

exit(1)

func.putlog("--Ок. Одна копия, работаем дальше");

func.putlog("--соединяемся с noc");

try:

conn = mysql.connector.connect(host=config.noc_host,database=config.noc_base,user=config.noc_user,password=config.noc_pass)

if conn.is_connected(): func.putlog('--cоединение с БД '+config.noc_base+' установлено')

except Error as e:

print("Ошибка: ",e);

exit(0);

finally:

func.putlog("---делаем выборку устройств для опроса");

sql="select * from oltlevels order by rand()";

cursor = conn.cursor(dictionary=True,buffered=True)

cursor.execute(sql);

row = cursor.fetchone()

while row is not None:

ip=row["ip"]

community=row["community"]

idr=row["id"]

ind=row["ind"]

func.putlog("----опрашиваем "+str(ip)+" ind="+str(ind)+",id="+str(idr));

thread = threading.Thread(target=worker, args=(ip,community,ind,idr,)).start()

while threading.active_count() >workcount:

time.sleep(1)

row = cursor.fetchone()

while threading.active_count() >workcount:

time.sleep(1)

func.putlog("---закончили");

Оставить комментарий gpon, mysql, olt, python, snmp

Включаем и выключаем порты на свичах Dlink, SNR, QSW скрипт на Python

20.05.2016 Павел Грибов Python

Задача: считать текущий статус порта, и в зависимости от него или выключить порт, или включить.

Решение: скрипт на python

# coding=utf-8
from pysnmp.hlapi import *
from pysnmp.entity.rfc3413.oneliner import cmdgen
from pysnmp.proto import rfc1902

def GetPortStatus(ip,comm,oid):
 rez=None	    
 try:
    errorIndication, errorStatus, errorIndex, varBinds = next(
       getCmd(SnmpEngine(),
	      CommunityData(comm),
	      UdpTransportTarget(
		  (ip, 161), timeout=2.0, retries=0
	      ),
	      ContextData(),
	      ObjectType(ObjectIdentity(oid)))
    )

    if errorIndication:
       print(errorIndication)
       return rez
    elif errorStatus:
       print('%s at %s' % (errorStatus.prettyPrint(),
			   errorIndex and varBinds[int(errorIndex) - 1][0] or '?'))
       return rez			
    else:
       for varBind in varBinds:      
	 if str(varBind).find("up")>0: rez=1;
	 if str(varBind).find("down")>0: rez=2;
	 if rez==None:
	   zx=str(varBind).split("=");
	   rez=zx[1].replace(" ","");      
 except:	       
     rez=None   
 return rez

def SetPortStatus(ip,comm,oid,status):
 rez=None	          
 try:
    cmdGen = cmdgen.CommandGenerator()
    errorIndication, errorStatus, errorIndex, varBinds = cmdGen.setCmd(
       cmdgen.CommunityData(comm,mpModel=1),
       cmdgen.UdpTransportTarget((ip, 161)),
	(oid, rfc1902.Integer(status)),    
    )
    # Check for errors and print out results
    if errorIndication:
       print(errorIndication)
    else:
       if errorStatus:
	   print('%s at %s' % (
	       errorStatus.prettyPrint(),
	       errorIndex and varBinds[int(errorIndex)-1] or '?'
	       )
	   )
	   rez=None
       else:
	   for name, val in varBinds:
	       print('%s = %s' % (name.prettyPrint(), val.prettyPrint()))    
	       rez=True
 except:	       
     rez=None
 return rez
#снимает статус порта	
#dlink
# oid=1.3.6.1.2.1.2.2.1.8.x
# x - номер порта
rz=GetPortStatus('12.1.14.6','XFiles','1.3.6.1.2.1.2.2.1.8.9')	
print "Dlink: ",rz
#snr
rz=GetPortStatus('72.1.14.201','X-Files','1.3.6.1.2.1.2.2.1.8.3')	
print "SNR: ",rz
#qsw
rz=GetPortStatus('72.1.114.201','X-Files','1.3.6.1.2.1.2.2.1.8.3')	
print "QSW: ",rz

#устанавливаем статус порта
#up=1,down=2
#oid=1.3.6.1.2.1.2.2.1.7.9.x
# x - номер порта
#Dlink
rz=SetPortStatus('72.8.114.4','X-Files','1.3.6.1.2.1.2.2.1.7.9',1)
print rz;
#SNR
rz=SetPortStatus('72.7.114.196','X-Files','1.3.6.1.2.1.2.2.1.7.8',1)
print rz;
#QSR
rz=SetPortStatus('12.1.114.100','X-Files','1.3.6.1.2.1.2.2.1.7.3',1)
print rz;

# coding=utf-8

from pysnmp.hlapi import *

from pysnmp.entity.rfc3413.oneliner import cmdgen

from pysnmp.proto import rfc1902

def GetPortStatus(ip,comm,oid):

rez=None

try:

errorIndication, errorStatus, errorIndex, varBinds = next(

getCmd(SnmpEngine(),

CommunityData(comm),

UdpTransportTarget(

(ip, 161), timeout=2.0, retries=0

ContextData(),

ObjectType(ObjectIdentity(oid)))

)

if errorIndication:

print(errorIndication)

return rez

elif errorStatus:

print('%s at %s' % (errorStatus.prettyPrint(),

errorIndex and varBinds[int(errorIndex) - 1][0] or '?'))

return rez

else:

for varBind in varBinds:

if str(varBind).find("up")>0: rez=1;

if str(varBind).find("down")>0: rez=2;

if rez==None:

zx=str(varBind).split("=");

rez=zx[1].replace(" ","");

except:

rez=None

return rez

def SetPortStatus(ip,comm,oid,status):

rez=None

try:

cmdGen = cmdgen.CommandGenerator()

errorIndication, errorStatus, errorIndex, varBinds = cmdGen.setCmd(

cmdgen.CommunityData(comm,mpModel=1),

cmdgen.UdpTransportTarget((ip, 161)),

(oid, rfc1902.Integer(status)),

)

# Check for errors and print out results

if errorIndication:

print(errorIndication)

else:

if errorStatus:

print('%s at %s' % (

errorStatus.prettyPrint(),

errorIndex and varBinds[int(errorIndex)-1] or '?'

)

rez=None

else:

for name, val in varBinds:

print('%s = %s' % (name.prettyPrint(), val.prettyPrint()))

rez=True

except:

rez=None

return rez

#снимает статус порта

#dlink

# oid=1.3.6.1.2.1.2.2.1.8.x

# x - номер порта

rz=GetPortStatus('12.1.14.6','XFiles','1.3.6.1.2.1.2.2.1.8.9')

print "Dlink: ",rz

#snr

rz=GetPortStatus('72.1.14.201','X-Files','1.3.6.1.2.1.2.2.1.8.3')

print "SNR: ",rz

#qsw

rz=GetPortStatus('72.1.114.201','X-Files','1.3.6.1.2.1.2.2.1.8.3')

print "QSW: ",rz

#устанавливаем статус порта

#up=1,down=2

#oid=1.3.6.1.2.1.2.2.1.7.9.x

# x - номер порта

#Dlink

rz=SetPortStatus('72.8.114.4','X-Files','1.3.6.1.2.1.2.2.1.7.9',1)

print rz;

#SNR

rz=SetPortStatus('72.7.114.196','X-Files','1.3.6.1.2.1.2.2.1.7.8',1)

print rz;

#QSR

rz=SetPortStatus('12.1.114.100','X-Files','1.3.6.1.2.1.2.2.1.7.3',1)

print rz;

Оставить комментарий pysnmp example, pysnmp примеры, python, snmp, включение порта, статус порта, управление свичем

Работаем на python с протоколом snmp

20.05.2016 Павел Грибов Python

Есть несколько модулей, которые помогают работать с snmp на python. Гугл в помощь какие. Наиболее популярный: pysnmp. В Ubuntu ставится как:

pip install pysnmp

1	pip install pysnmp

Напишем на Python аналог команды из консоли, которая получает список мак адресов на портах свичей Dlink:

snmpwalk -v2c -c XFiles 172.18.114.6 1.3.6.1.2.1.17.7.1.2.2.1.2

1	snmpwalk -v2c -c XFiles 172.18.114.6 1.3.6.1.2.1.17.7.1.2.2.1.2

Код:

from pysnmp.entity.rfc3413.oneliner import cmdgen

cmdGen = cmdgen.CommandGenerator()

errorIndication, errorStatus, errorIndex, varBindTable = cmdGen.nextCmd(
    cmdgen.CommunityData('XFiles'),
    cmdgen.UdpTransportTarget(('172.18.114.6', 161)),
    '1.3.6.1.2.1.17.7.1.2.2.1.2'    
)

if errorIndication:
    print(errorIndication)
else:
    if errorStatus:
        print('%s at %s' % (
            errorStatus.prettyPrint(),
            errorIndex and varBindTable[-1][int(errorIndex)-1] or '?'
            )
        )
    else:
        for varBindTableRow in varBindTable:
            for name, val in varBindTableRow:
                print('%s = %s' % (name.prettyPrint(), val.prettyPrint()))

from pysnmp.entity.rfc3413.oneliner import cmdgen

cmdGen = cmdgen.CommandGenerator()

errorIndication, errorStatus, errorIndex, varBindTable = cmdGen.nextCmd(

cmdgen.CommunityData('XFiles'),

cmdgen.UdpTransportTarget(('172.18.114.6', 161)),

'1.3.6.1.2.1.17.7.1.2.2.1.2'

)

if errorIndication:

print(errorIndication)

else:

if errorStatus:

print('%s at %s' % (

errorStatus.prettyPrint(),

errorIndex and varBindTable[-1][int(errorIndex)-1] or '?'

)

else:

for varBindTableRow in varBindTable:

for name, val in varBindTableRow:

print('%s = %s' % (name.prettyPrint(), val.prettyPrint()))

2 комментария python, snmp, snmpwalk

Определение состояния порта на свичах Dlink на PHP

04.02.2015 Павел Грибов PHP

<?php

// Данный код создан и распространяется по лицензии GPL v3
// Изначальный автор данного кода - Грибов Павел
// http://грибовы.рф

function GetEnt($res){
    $zz=explode("INTEGER:", $res);
    if (is_array($zz)==true) {return trim($zz[1]);} else
    {return "";};
};

//запускаем тест проверки кабеля

 $res=shell_exec("snmpset -v2c -c X-Files $devip 1.3.6.1.4.1.171.12.58.1.1.1.12.$port i 1");
 $res=GetEnt($res);
 if ($res=="1"){
 //проверяем что он завершился:
 $res=shell_exec("snmpget -v2c -c X-Files $devip 1.3.6.1.4.1.171.12.58.1.1.1.12.$port");
 $res=GetEnt($res);
 if ($res!="3"){
     //еще разок тестанем!
     $res=shell_exec("snmpget -v2c -c X-Files $devip 1.3.6.1.4.1.171.12.58.1.1.1.12.$port");
     $res=GetEnt($res);
 };
 if ($res=="3"){
   //есть ли линк?
   $res=shell_exec("snmpget -v2c -c X-Files $devip 1.3.6.1.4.1.171.12.58.1.1.1.3.$port");
   $res=GetEnt($res);
   if ($res=="1"){echo "-линк есть</br>";} else {echo "-линка нет</br>";};
   //состояние 1 пары
   $res=shell_exec("snmpget -v2c -c X-Files $devip 1.3.6.1.4.1.171.12.58.1.1.1.4.$port");
   $res=GetEnt($res);
   if ($res=="0"){echo "-1 пара ОК</br>";} else {echo "-1 пара BAD</br>";};
   //состояние 2 пары
   $res=shell_exec("snmpget -v2c -c X-Files $devip 1.3.6.1.4.1.171.12.58.1.1.1.5.$port");
   $res=GetEnt($res);
   if ($res=="0"){echo "-2 пара ОК</br>";} else {echo "-2 пара BAD</br>";};
   //состояние 3 пары
   $res=shell_exec("snmpget -v2c -c X-Files $devip 1.3.6.1.4.1.171.12.58.1.1.1.6.$port");
   $res=GetEnt($res);
   if ($res=="0"){echo "-3 пара ОК</br>";} else {echo "-3 пара BAD</br>";};
   //состояние 4 пары
   $res=shell_exec("snmpget -v2c -c X-Files $devip 1.3.6.1.4.1.171.12.58.1.1.1.7.$port");
   $res=GetEnt($res);
   if ($res=="0"){echo "-4 пара ОК</br>";} else {echo "-4 пара BAD</br>";};
   
   //определяем длинну пар
   $res=shell_exec("snmpget -v2c -c X-Files $devip 1.3.6.1.4.1.171.12.58.1.1.1.8.$port");
   $res=GetEnt($res);
   echo "-длина 1 пары $res</br>";
   $res=shell_exec("snmpget -v2c -c X-Files $devip 1.3.6.1.4.1.171.12.58.1.1.1.9.$port");
   $res=GetEnt($res);
   echo "-длина 2 пары $res</br>";
   $res=shell_exec("snmpget -v2c -c X-Files $devip 1.3.6.1.4.1.171.12.58.1.1.1.10.$port");
   $res=GetEnt($res);
   echo "-длина 3 пары $res</br>";
   $res=shell_exec("snmpget -v2c -c X-Files $devip 1.3.6.1.4.1.171.12.58.1.1.1.11.$port");
   $res=GetEnt($res);                              
   echo "-длина 4 пары $res</br>";
   
   //Определяем состояние кабеля
   $res=shell_exec("snmpset -v2c -c X-Files $devip 1.3.6.1.4.1.171.12.58.1.1.1.12.$port i 1");
   $res=shell_exec("snmpget -v2c -c X-Files $devip 1.3.6.1.4.1.171.12.58.1.1.1.4.$port");
   $res=GetEnt($res);
   if ($res=="8") {echo "-Кабель не подключен</br>";};
   if ($res=="1") {echo "-Кабель воткнут с одной стороны (второй конец висит в воздухе)</br>";};
     
   
 } else {
 ?>
    <div class="alert alert-error">
        Не удалось завершить опрос пары!
    </div>
 <?php
};
 } else {
 ?>
    <div class="alert alert-error">
        Не удалось выполнить SNMP запрос!
    </div>
 <?php
};

<?php

// Данный код создан и распространяется по лицензии GPL v3

// Изначальный автор данного кода - Грибов Павел

// http://грибовы.рф

function GetEnt($res){

$zz=explode("INTEGER:", $res);

if (is_array($zz)==true) {return trim($zz[1]);} else

{return "";};

};

//запускаем тест проверки кабеля

$res=shell_exec("snmpset -v2c -c X-Files $devip 1.3.6.1.4.1.171.12.58.1.1.1.12.$port i 1");

$res=GetEnt($res);

if ($res=="1"){

//проверяем что он завершился:

$res=shell_exec("snmpget -v2c -c X-Files $devip 1.3.6.1.4.1.171.12.58.1.1.1.12.$port");

$res=GetEnt($res);

if ($res!="3"){

//еще разок тестанем!

$res=shell_exec("snmpget -v2c -c X-Files $devip 1.3.6.1.4.1.171.12.58.1.1.1.12.$port");

$res=GetEnt($res);

};

if ($res=="3"){

//есть ли линк?

$res=shell_exec("snmpget -v2c -c X-Files $devip 1.3.6.1.4.1.171.12.58.1.1.1.3.$port");

$res=GetEnt($res);

if ($res=="1"){echo "-линк есть</br>";} else {echo "-линка нет</br>";};

//состояние 1 пары

$res=shell_exec("snmpget -v2c -c X-Files $devip 1.3.6.1.4.1.171.12.58.1.1.1.4.$port");

$res=GetEnt($res);

if ($res=="0"){echo "-1 пара ОК</br>";} else {echo "-1 пара BAD</br>";};

//состояние 2 пары

$res=shell_exec("snmpget -v2c -c X-Files $devip 1.3.6.1.4.1.171.12.58.1.1.1.5.$port");

$res=GetEnt($res);

if ($res=="0"){echo "-2 пара ОК</br>";} else {echo "-2 пара BAD</br>";};

//состояние 3 пары

$res=shell_exec("snmpget -v2c -c X-Files $devip 1.3.6.1.4.1.171.12.58.1.1.1.6.$port");

$res=GetEnt($res);

if ($res=="0"){echo "-3 пара ОК</br>";} else {echo "-3 пара BAD</br>";};

//состояние 4 пары

$res=shell_exec("snmpget -v2c -c X-Files $devip 1.3.6.1.4.1.171.12.58.1.1.1.7.$port");

$res=GetEnt($res);

if ($res=="0"){echo "-4 пара ОК</br>";} else {echo "-4 пара BAD</br>";};

//определяем длинну пар

$res=shell_exec("snmpget -v2c -c X-Files $devip 1.3.6.1.4.1.171.12.58.1.1.1.8.$port");

$res=GetEnt($res);

echo "-длина 1 пары $res</br>";

$res=shell_exec("snmpget -v2c -c X-Files $devip 1.3.6.1.4.1.171.12.58.1.1.1.9.$port");

$res=GetEnt($res);

echo "-длина 2 пары $res</br>";

$res=shell_exec("snmpget -v2c -c X-Files $devip 1.3.6.1.4.1.171.12.58.1.1.1.10.$port");

$res=GetEnt($res);

echo "-длина 3 пары $res</br>";

$res=shell_exec("snmpget -v2c -c X-Files $devip 1.3.6.1.4.1.171.12.58.1.1.1.11.$port");

$res=GetEnt($res);

echo "-длина 4 пары $res</br>";

//Определяем состояние кабеля

$res=shell_exec("snmpset -v2c -c X-Files $devip 1.3.6.1.4.1.171.12.58.1.1.1.12.$port i 1");

$res=shell_exec("snmpget -v2c -c X-Files $devip 1.3.6.1.4.1.171.12.58.1.1.1.4.$port");

$res=GetEnt($res);

if ($res=="8") {echo "-Кабель не подключен</br>";};

if ($res=="1") {echo "-Кабель воткнут с одной стороны (второй конец висит в воздухе)</br>";};

} else {

Не удалось завершить опрос пары!

</div>

<?php

};

} else {

Не удалось выполнить SNMP запрос!

</div>

<?php

};

Сделано по мотивам: http://wiki.sirmax.noname.com.ua/index.php/Dlink_Cable_Tester

Оставить комментарий dlink, php, snmp, остояние портов

Пн	Вт	Ср	Чт	Пт	Сб	Вс
						1
2	3	4	5	6	7	8
9	10	11	12	13	14	15
16	17	18	19	20	21	22
23	24	25	26	27	28	29
30	31