0

我已经为获取陷阱编写了陷阱接收器程序，但现在我想为我的服务器编写自定义代理，将陷阱发送到陷阱接收器
，但样本太差，对我没有多大帮助。样本是： 

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

我需要我的代理发送正常运行时间、温度、CPU 使用率、RAM 使用率等

4

0 回答 0