сторона агента pysnmp-make для отправки необходимых ловушек - PullRequest
0 голосов
/ 20 мая 2018

Я уже пишу свою программу-получатель ловушек для получения ловушек, но теперь я хочу написать собственный агент для моих серверов, который отправляет ловушки получателю ловушек
, но пример слишком беден и не может мне сильно помочь.Пример:

from pysnmp.carrier.asyncore.dispatch import AsyncoreDispatcher
from pysnmp.carrier.asyncore.dgram import udp, udp6, unix
from pyasn1.codec.ber import decoder
from pysnmp.proto import api


# noinspection PyUnusedLocal
def cbFun(transportDispatcher, transportDomain, transportAddress, wholeMsg):
while wholeMsg:
    msgVer = int(api.decodeMessageVersion(wholeMsg))
    if msgVer in api.protoModules:
        pMod = api.protoModules[msgVer]
    else:
        print('Unsupported SNMP version %s' % msgVer)
        return
    reqMsg, wholeMsg = decoder.decode(
        wholeMsg, asn1Spec=pMod.Message(),
    )
    print('Notification message from %s:%s: ' % (
        transportDomain, transportAddress
    )
          )
    reqPDU = pMod.apiMessage.getPDU(reqMsg)
    if reqPDU.isSameTypeWith(pMod.TrapPDU()):
        if msgVer == api.protoVersion1:
            print('Enterprise: %s' % (pMod.apiTrapPDU.getEnterprise(reqPDU).prettyPrint()))
            print('Agent Address: %s' % (pMod.apiTrapPDU.getAgentAddr(reqPDU).prettyPrint()))
            print('Generic Trap: %s' % (pMod.apiTrapPDU.getGenericTrap(reqPDU).prettyPrint()))
            print('Specific Trap: %s' % (pMod.apiTrapPDU.getSpecificTrap(reqPDU).prettyPrint()))
            print('Uptime: %s' % (pMod.apiTrapPDU.getTimeStamp(reqPDU).prettyPrint()))
            varBinds = pMod.apiTrapPDU.getVarBinds(reqPDU)
        else:
            varBinds = pMod.apiPDU.getVarBinds(reqPDU)
        print('Var-binds:')
        for oid, val in varBinds:
            print('%s = %s' % (oid.prettyPrint(), val.prettyPrint()))
return wholeMsg


transportDispatcher = AsyncoreDispatcher()

transportDispatcher.registerRecvCbFun(cbFun)

# UDP/IPv4
transportDispatcher.registerTransport(
udp.domainName, udp.UdpSocketTransport().openServerMode(('localhost', 162))
)

# UDP/IPv6
transportDispatcher.registerTransport(
udp6.domainName, udp6.Udp6SocketTransport().openServerMode(('::1', 162))
)

## Local domain socket
# transportDispatcher.registerTransport(
#    unix.domainName, unix.UnixSocketTransport().openServerMode('/tmp/snmp-manager')
# )

transportDispatcher.jobStarted(1)

try:
    # Dispatcher will never finish as job#1 never reaches zero
    transportDispatcher.runDispatcher()
except:
    transportDispatcher.closeDispatcher()
    raise

Мне нужно время, необходимое для отправки агенту, температура, загрузка ЦП, использование ОЗУ и т. д.

...