Python api.decodeMessageVersion函数代码示例

OGeek|极客世界-中国程序员成长平台 › 门户 › 编程› Python›Python编程经验

原作者: [db:作者] 来自: [db:来源] 收藏邀请

本文整理汇总了Python中pysnmp.proto.api.decodeMessageVersion函数的典型用法代码示例。如果您正苦于以下问题：Python decodeMessageVersion函数的具体用法？Python decodeMessageVersion怎么用？Python decodeMessageVersion使用的例子？那么恭喜您, 这里精选的函数代码示例或许可以为您提供帮助。

在下文中一共展示了decodeMessageVersion函数的20个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的Python代码示例。

示例1: cbFun

def cbFun(transportDispatcher, transportDomain, transportAddress, wholeMsg):
    while wholeMsg:
        msgVer = int(api.decodeMessageVersion(wholeMsg))
        if api.protoModules.has_key(msgVer):
            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.getVarBindList(reqPDU)
            else:
                varBinds = pMod.apiPDU.getVarBindList(reqPDU)
            print "Var-binds:"
            for oid, val in varBinds:
                print "%s = %s" % (oid.prettyPrint(), val.prettyPrint())
    return wholeMsg

开发者ID:shimo85，项目名称:pysnmp，代码行数:25，代码来源:ntfrcv.py

示例2: receive_message

    def receive_message(self, host, port, data):
        """ Called when we received a SNMP message on the configured port. """
        snmp_version = int(api.decodeMessageVersion(data))
        if snmp_version in api.protoModules:
            prot_module = api.protoModules[snmp_version]
        elif snmp_version == 3:
            self.parse_snmpv3_trap(data, host)
            return
        else:
            raise UnsupportedSNMPVersion(snmp_version)

        message, temp = decoder.decode(data, asn1Spec=prot_module.Message())
        # print message

        # If configured, check if the community string matches
        recv_community = prot_module.apiMessage.getCommunity(message)
        # print recv_community
        if self.check_community_string and\
            recv_community != self.community_string:
            raise InvalidCommunityString(host, port, recv_community)

        recv_pdu = prot_module.apiMessage.getPDU(message)

        # Only accepting SNMP Trap PDU's
        if not recv_pdu.isSameTypeWith(prot_module.TrapPDU()):
            raise InvalidSNMPType(host, port)

        # Only supporting SNMPv1 and SNMPv2 at the moment
        if snmp_version == api.protoVersion1:
            self.parse_snmpv1_pdu(prot_module, recv_pdu)
        elif snmp_version == api.protoVersion2c:
            self.parse_snmpv2_pdu(prot_module, recv_pdu, host)
        else:
            raise UnsupportedSNMPVersion(snmp_version)

开发者ID:umitproject，项目名称:network-inventory，代码行数:34，代码来源:SNMPListener.py

示例3: cbFun

def cbFun(transportDispatcher, transportDomain, transportAddress, wholeMsg):
    while wholeMsg:
        msgVer = 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(),
        )
        rspMsg = pMod.apiMessage.getResponse(reqMsg)
        rspPDU = pMod.apiMessage.getPDU(rspMsg)
        reqPDU = pMod.apiMessage.getPDU(reqMsg)
        varBinds = []
        pendingErrors = []
        errorIndex = 0
        # GETNEXT PDU
        if reqPDU.isSameTypeWith(pMod.GetNextRequestPDU()):
            # Produce response var-binds
            for oid, val in pMod.apiPDU.getVarBinds(reqPDU):
                errorIndex = errorIndex + 1
                # Search next OID to report
                nextIdx = bisect.bisect(mibInstr, oid)
                if nextIdx == len(mibInstr):
                    # Out of MIB
                    varBinds.append((oid, val))
                    pendingErrors.append(
                        (pMod.apiPDU.setEndOfMibError, errorIndex)
                    )
                else:
                    # Report value if OID is found
                    varBinds.append(
                        (mibInstr[nextIdx].name, mibInstr[nextIdx](msgVer))
                    )
        elif reqPDU.isSameTypeWith(pMod.GetRequestPDU()):
            for oid, val in pMod.apiPDU.getVarBinds(reqPDU):
                if oid in mibInstrIdx:
                    varBinds.append((oid, mibInstrIdx[oid](msgVer)))
                else:
                    # No such instance
                    varBinds.append((oid, val))
                    pendingErrors.append(
                        (pMod.apiPDU.setNoSuchInstanceError, errorIndex)
                    )
                    break
        else:
            # Report unsupported request type
            pMod.apiPDU.setErrorStatus(rspPDU, 'genErr')
        pMod.apiPDU.setVarBinds(rspPDU, varBinds)
        # Commit possible error indices to response PDU
        for f, i in pendingErrors:
            f(rspPDU, i)
        transportDispatcher.sendMessage(
            encoder.encode(rspMsg), transportDomain, transportAddress
        )
    return wholeMsg

开发者ID:crazy-canux，项目名称:pysnmp，代码行数:57，代码来源:implementing-scalar-mib-objects.py

示例4: cbFun

    def cbFun(self, transportDispatcher, transportDomain,
            cbCtx, wholeMsg, ):

        print "cbCtx :", cbCtx

        msgVer = int(api.decodeMessageVersion(wholeMsg))
	    #print "Inisde CB FUN..."
           
        
        print 'Inside CB FUN....'

        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(),
    	)

        self.req = reqMsg

        print 'Type :', type(self.req)

        print 'Inform :', self.inform

        if self.inform:
            print 'Inside Inform IF........'
            if not 'InformRequestPDU()' in str(self.req):
                print 'Inform Message is not sent....failed...'



        print 'reqMsg : %s' % self.req
        #print 'wholeMsg : %s' % wholeMsg

    	#print('Notification message from %s:%s: ' % (
        #    transportDomain, transportAddress
        #    )
    	#)
    	reqPDU = pMod.apiMessage.getPDU(reqMsg)

        print ',,,,reqPDU : %s' % reqPDU
    	varBinds = pMod.apiPDU.getVarBindList(reqPDU)
    	#transportDispatcher.jobFinished(1)
	    
        self.terminationRequestedFlag = True
        if msgVer == api.protoVersion1:
	        self.varBinds = pMod.apiTrapPDU.getVarBindList(reqPDU)
	        self.specificTrap = pMod.apiTrapPDU.getSpecificTrap(reqPDU).prettyPrint()
	        self.version = 1 
	    
        if msgVer == api.protoVersion2c:
	        self.varBinds = pMod.apiPDU.getVarBindList(reqPDU)
	        self.specificTrap = None	
	        self.version = 2

开发者ID:terafastnetworks，项目名称:snmp_trap，代码行数:57，代码来源:trap_receiver.py

示例5: cbFun

    def cbFun(self, transportDispatcher, transportDomain, transportAddress, wholeMsg): #response
        print 'cbFun'
        while wholeMsg:
            msgVer = 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(),
                )
            rspMsg = pMod.apiMessage.getResponse(reqMsg)
            rspPDU = pMod.apiMessage.getPDU(rspMsg)        
            reqPDU = pMod.apiMessage.getPDU(reqMsg)
            varBinds = []
            pendingErrors = []
            session_data = {}
            errorIndex = 0
            
            # 
            if reqPDU.isSameTypeWith(pMod.SetRequestPDU()):
                #parser
                for oid, val in pMod.apiPDU.getVarBinds(reqPDU):
                    print oid
                    print val
                    if oid in self._mib_instr_idx:
                        session_data[self._mib_instr_idx[oid].title] = str(val)
                        varBinds.append((oid, self._mib_instr_idx[oid](msgVer)))
                    else:
                        # No such instance
                        varBinds.append((oid, val))
                        pendingErrors.append(
                            (pMod.apiPDU.setNoSuchInstanceError, errorIndex)
                            )
                        break
                
            else:
                # Report unsupported request type
                pMod.apiPDU.setErrorStatus(rspPDU, 'genErr')
            
            pMod.apiPDU.setVarBinds(rspPDU, varBinds)
            
            try:
                self._fakebras.stop_session(session_data, True)
            except Exception as error:
                raise

            # Commit possible error indices to response PDU
            for f, i in pendingErrors:
                f(rspPDU, i)
            
            transportDispatcher.sendMessage(
                encoder.encode(rspMsg), transportDomain, transportAddress
                )
        return wholeMsg

开发者ID:EMamoshin，项目名称:fakebras，代码行数:56，代码来源:snmp_agent.py

示例6: cbFun

def cbFun(transportDispatcher, transportDomain, transportAddress, wholeMsg):
    global count_i
    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 '\nIndex: %d********************************************************************************' % count_i
        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.getVarBindList(reqPDU)
            else:
                varBinds = pMod.apiPDU.getVarBindList(reqPDU)
            # print('Var-binds:')
            # print 'oid\t\t\ttype\t\t\tvalue'
            print 'OID' + ' ' * 32 + 'VALUE'
            for oid, val in varBinds:
                # print('%s = %s' % (oid.prettyPrint(), val.prettyPrint().encode('utf-8')))
                oid = oid.prettyPrint()
                sva = val.prettyPrint().encode('utf-8')
                spr = sva[sva.rfind('value=') + 6:].strip()
                print oid + ' ' * (35 - len(oid)) + spr
                # prt = spr.split('=')
                # print '%s\t\t\t%s\t\t\t%s' % (oid, prt[0], prt[1])
    return wholeMsg

开发者ID:lowitty，项目名称:zacademy，代码行数:55，代码来源:trapreciever_v1v2.py

示例7: onSnmpMessage

	def onSnmpMessage(self, transportDispatcher, transportDomain, transportAddress, wholeMsg):
		while wholeMsg:
			msgVer = api.decodeMessageVersion(wholeMsg)
			if api.protoModules.has_key(msgVer):
				pMod = api.protoModules[msgVer]
			else:
				getLogger().error('Unsupported SNMP version %s' % msgVer)
				return
			reqMsg, wholeMsg = decoder.decode(wholeMsg, asn1Spec=pMod.Message(), )
			rspMsg = pMod.apiMessage.getResponse(reqMsg)
			rspPDU = pMod.apiMessage.getPDU(rspMsg)		
			reqPDU = pMod.apiMessage.getPDU(reqMsg)
			varBinds = []
			errorIndex = -1

			# GET request
			if reqPDU.isSameTypeWith(pMod.GetRequestPDU()):
				getLogger().info("SNMP GET received...")
				for oid, val in pMod.apiPDU.getVarBinds(reqPDU):
					getLogger().debug("Trying to GET %s... " % oidToString(oid))
					if mibVariablesByOid.has_key(oid):
						varBinds.append((oid, mibVariablesByOid[oid](msgVer)))
					else:
						# No such instance
						pMod.apiPDU.setNoSuchInstanceError(rspPDU, errorIndex)
						varBinds = pMod.apiPDU.getVarBinds(reqPDU)
						break

			# GET-NEXT request
			elif reqPDU.isSameTypeWith(pMod.GetNextRequestPDU()):
				getLogger().info("SNMP GET-NEXT received...")
				# Produce response var-binds
				errorIndex = -1
				for oid, val in pMod.apiPDU.getVarBinds(reqPDU):
					getLogger().debug("Trying to GET-NEXT %s... " % oidToString(oid))
					errorIndex = errorIndex + 1
					# Search next OID to report
					nextIdx = bisect.bisect(mibVariables, oid)
					if nextIdx == len(mibVariables):
						# Out of MIB
						pMod.apiPDU.setEndOfMibError(rspPDU, errorIndex)
					else:
						# Report value if OID is found
						varBinds.append((mibVariables[nextIdx].oid, mibVariables[nextIdx](msgVer)))

			else:
				getLogger().error("Unsupported SNMP request received...")
				# Report unsupported request type
				pMod.apiPDU.setErrorStatus(rspPDU, -1) # we should use something different from -1

			pMod.apiPDU.setVarBinds(rspPDU, varBinds)
			transportDispatcher.sendMessage(encoder.encode(rspMsg), transportDomain, transportAddress)
		return wholeMsg

开发者ID:rolfschr，项目名称:testerman，代码行数:53，代码来源:Snmp.py

示例8: newFn

def newFn(transportDispatcher, transportDomain, transportAddress, wholeMsg):
    print "Lights status:"
    print lights[0]
    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: %s ' % (
            transportDomain, transportAddress, wholeMsg
            )
        )
        """
        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.getVarBindList(reqPDU)
            else:
                varBinds = pMod.apiPDU.getVarBindList(reqPDU)
            for oid, val in varBinds:
                #print('%s = %s' % (oid.prettyPrint(), val.prettyPrint()))
                print "RECEIVED a TRAP Message from Light Agent :"
                lights[0] = (((str(val).split("OctetString('"))[1]).split("')))"))[0]
                print (((str(val).split("OctetString('"))[1]).split("')))"))[0]
    return wholeMsg

开发者ID:stephenoken，项目名称:-SNMP-Management-Station-for-Wireless-Indoor-Network，代码行数:53，代码来源:manager.py

示例9: _trap_receiver_cb

    def _trap_receiver_cb(transport, domain, sock, msg):
        if decodeMessageVersion(msg) != protoVersion2c:
            raise RuntimeError('Only SNMP v2c traps are supported.')

        req, msg = decoder.decode(msg, asn1Spec=v2c.Message())
        pdu = v2c.apiMessage.getPDU(req)

        # ignore any non trap PDUs
        if not pdu.isSameTypeWith(v2c.TrapPDU()):
            return

        if trap_filter(domain, sock, pdu):
            transport.jobFinished(1)

开发者ID:urtow，项目名称:robotframework-snmplibrary，代码行数:13，代码来源:traps.py

示例10: trapCallback

def trapCallback(transportDispatcher, transportDomain, transportAddress, wholeMsg):
    
    try:
        if not wholeMsg:
            logging.error('Receiving trap , error processing the inital message in the trapCallback handler')
            
        while wholeMsg:
            msgVer = int(api.decodeMessageVersion(wholeMsg))
            if msgVer in api.protoModules:
                pMod = api.protoModules[msgVer]
            else:
                logging.error('Receiving trap , unsupported SNMP version %s' % msgVer)
                return
            reqMsg, wholeMsg = decoder.decode(wholeMsg, asn1Spec=pMod.Message(),)
            
            reqPDU = pMod.apiMessage.getPDU(reqMsg)
            
            trap_metadata =""
            server = ""
            try:
                server = "%s" % transportAddress[0]
                trap_metadata += 'notification_from_address = "%s" ' % (transportAddress[0])
                trap_metadata += 'notification_from_port = "%s" ' % (transportAddress[1])
            except: # catch *all* exceptions
                e = sys.exc_info()[1]
                logging.error("Exception resolving source address/domain of the trap: %s" % str(e))
            
            if reqPDU.isSameTypeWith(pMod.TrapPDU()):
                if msgVer == api.protoVersion1:
                    if server == "":
                        server = pMod.apiTrapPDU.getAgentAddr(reqPDU).prettyPrint()

                    trap_metadata += 'notification_enterprise = "%s" ' % (pMod.apiTrapPDU.getEnterprise(reqPDU).prettyPrint())
                    trap_metadata += 'notification_agent_address = "%s" ' % (pMod.apiTrapPDU.getAgentAddr(reqPDU).prettyPrint())
                    trap_metadata += 'notification_generic_trap = "%s" ' % (pMod.apiTrapPDU.getGenericTrap(reqPDU).prettyPrint())
                    trap_metadata += 'notification_specific_trap = "%s" ' % (pMod.apiTrapPDU.getSpecificTrap(reqPDU).prettyPrint())
                    trap_metadata += 'notification_uptime = "%s" ' % (pMod.apiTrapPDU.getTimeStamp(reqPDU).prettyPrint())
                    
                    varBinds = pMod.apiTrapPDU.getVarBindList(reqPDU)
                else:
                    varBinds = pMod.apiPDU.getVarBindList(reqPDU)
                    
                      
                
            handle_output(varBinds,server,from_trap=True,trap_metadata=trap_metadata) 
            
    except: # catch *all* exceptions
        e = sys.exc_info()[1]
        logging.error("Exception receiving trap %s" % str(e))
                  
    return wholeMsg

开发者ID:cjthuys，项目名称:SplunkModularInputsPythonFramework，代码行数:51，代码来源:snmp.py

示例11: cbFun

 def cbFun(self,transportDispatcher, transportDomain, transportAddress, wholeMsg):  
     record = '' 
     record = record + '<snmpTrapPdu xmlns="http://huawei.com/common/trap">\n' 
     while wholeMsg:
         msgVer = int(api.decodeMessageVersion(wholeMsg))
         if msgVer in api.protoModules:
             pMod = api.protoModules[msgVer]
         else:
             logger.warning('Unsupported SNMP version %s' % msgVer)
             return
         reqMsg, wholeMsg = decoder.decode(
             wholeMsg, asn1Spec=pMod.Message(),
             )                             
         #logger.warning('Notification message from %s:%s: ' % (transportDomain, transportAddress))
         reqPDU = pMod.apiMessage.getPDU(reqMsg)
         community = pMod.apiMessage.getCommunity(reqMsg)
         timestamp = time.strftime('%Y-%m-%d %H:%M:%S',time.localtime(time.time()))
         
         if reqPDU.isSameTypeWith(pMod.TrapPDU()):
             if msgVer == api.protoVersion1:                    
                 Enterprise = (str)(pMod.apiTrapPDU.getEnterprise(reqPDU).prettyPrint()) 
                 agentaddr = pMod.apiTrapPDU.getAgentAddr(reqPDU).prettyPrint()
                 GenericTrapid = pMod.apiTrapPDU.getGenericTrap(reqPDU).prettyPrint()
                 SpecificTrapid = pMod.apiTrapPDU.getSpecificTrap(reqPDU).prettyPrint()
                 varBinds = pMod.apiTrapPDU.getVarBindList(reqPDU)
             else:                     
                 varBinds = pMod.apiPDU.getVarBindList(reqPDU) 
                 trapoid =  (str)(varBinds[1][1][0][0][2])
            
             ReceivedTrap = SnmpTrap(msgVer,transportDomain,transportAddress,varBinds)  
             
             trapvbs = ''
             for oid, val in varBinds:
                 #logger.warning ('%s = %s' % (oid.prettyPrint(), val.prettyPrint())) 
                 trapvbs = trapvbs + '<vb>'  
                 trapvbs = trapvbs + '\n        <oid>' + oid.prettyPrint() + '</oid>' 
                 #print (val.getComponent(1)).prettyPrint()
                 value = (val.getComponent(1)).prettyPrint()
                 trapvbs = trapvbs + '\n        <value>' + value + '</value>\n'  
                 trapvbs = trapvbs + '        </vb>\n'  
                        
             #no print community message
             if msgVer == api.protoVersion1:
                 traprecord = v1trapformat%(timestamp,agentaddr,Enterprise,GenericTrapid,SpecificTrapid,trapvbs)
             else:
                 traprecord = v2trapformat%(timestamp,transportAddress[0],trapoid,trapvbs)
             #print traprecord     
             logger.warning(traprecord)                          
             for i in self._dispatchers:                    
                 i.dispatch(ReceivedTrap, traprecord)

开发者ID:my76128，项目名称:OPS2，代码行数:50，代码来源:snmp_traprcv.py

示例12: _on_trap

    def _on_trap(self, transport_dispatcher, transport_domain,
                 transport_address, whole_msg):
        """ This method is called from pysnmp whenever a trap is received
        """
        self.logger.debug('Trap received')
        signals = []
        while whole_msg:
            signal_data = {}
            msg_ver = int(api.decodeMessageVersion(whole_msg))
            if msg_ver in api.protoModules:
                p_mod = api.protoModules[msg_ver]
            else:
                self.logger.warning('Unsupported SNMP version %s' % msg_ver)
                return
            req_msg, whole_msg = decoder.decode(
                whole_msg, asn1Spec=p_mod.Message(),)

            self.logger.info('Notification message from %s:%s: ' % (
                transport_domain, transport_address))
            signal_data["transport_domain"] = \
                str(oid_parser(transport_domain))
            signal_data["transport_address"] = \
                str(oid_parser(transport_address))

            req_pdu = p_mod.apiMessage.getPDU(req_msg)
            if req_pdu.isSameTypeWith(p_mod.TrapPDU()):
                if msg_ver == api.protoVersion1:
                    signal_data["enterprise"] = \
                        p_mod.apiTrapPDU.getEnterprise(req_pdu).prettyPrint()
                    signal_data["agent address"] = \
                        p_mod.apiTrapPDU.getAgentAddr(req_pdu).prettyPrint()
                    signal_data["generic trap"] = \
                        p_mod.apiTrapPDU.getGenericTrap(req_pdu).prettyPrint()
                    signal_data["specific trap"] = \
                        p_mod.apiTrapPDU.getSpecificTrap(req_pdu).prettyPrint()
                    signal_data["uptime"] = \
                        p_mod.apiTrapPDU.getTimeStamp(req_pdu).prettyPrint()
                    var_binds = p_mod.apiTrapPDU.getVarBindList(req_pdu)
                else:
                    var_binds = p_mod.apiPDU.getVarBindList(req_pdu)
                signal_data["var-binds"] = {}
                for item in var_binds:
                    oid = item[0]
                    val = item[1]
                    signal_data["var-binds"][str(oid_parser(oid._value))] = \
                        self._get_var_bind_data(val)
            signals.append(Signal(signal_data))
        if len(signals):
            self.notify_signals(signals, "trap")

开发者ID:nio-blocks，项目名称:snmp，代码行数:49，代码来源:snmp_trap_block.py

示例13: unpack_msg

    def unpack_msg(self, msg):
        """Unpack a SNMP message
        """
        self.version = api.decodeMessageVersion(msg)
        pMod = api.protoModules[int(self.version)]

        snmp_msg, m = decoder.decode(msg,
                                     asn1Spec=pMod.Message())
        snmp_pdu = pMod.apiMessage.getPDU(snmp_msg)
        snmp_error = pMod.apiPDU.getErrorStatus(snmp_pdu)

        self.community = pMod.apiMessage.getCommunity(snmp_msg)
        self.isTrap = snmp_pdu.isSameTypeWith(pMod.TrapPDU())

        return (snmp_msg, snmp_pdu, snmp_error)

开发者ID:sharifelshenawy，项目名称:yapc，代码行数:15，代码来源:snmp.py

示例14: handleSnmpMessage

def handleSnmpMessage(d, t, private={}):
    msgVer = api.decodeMessageVersion(d['data'])
    if msgVer in api.protoModules:
        pMod = api.protoModules[msgVer]
    else:
        stats['bad packets'] +=1
        return
    try:
        rspMsg, wholeMsg = decoder.decode(
            d['data'], asn1Spec=pMod.Message(),
        )
    except PyAsn1Error:
        stats['bad packets'] +=1
        return
    if rspMsg['data'].getName() == 'response':
        rspPDU = pMod.apiMessage.getPDU(rspMsg)
        errorStatus = pMod.apiPDU.getErrorStatus(rspPDU)
        if errorStatus:
            stats['SNMP errors'] +=1
        else:
            endpoint = d['source_address'], d['source_port']
            if endpoint not in endpoints:
                endpoints[endpoint] = udp.domainName + (transportIdOffset + len(endpoints),)
                stats['agents seen'] +=1
            context = '%s/%s' % (pMod.ObjectIdentifier(endpoints[endpoint]), pMod.apiMessage.getCommunity(rspMsg))
            if context not in contexts:
                contexts[context] = {}
                stats['contexts seen'] +=1
            context = '%s/%s' % (pMod.ObjectIdentifier(endpoints[endpoint]), pMod.apiMessage.getCommunity(rspMsg))

            stats['Response PDUs seen'] += 1

            if 'basetime' not in private:
                private['basetime'] = t

            for oid, value in pMod.apiPDU.getVarBinds(rspPDU):
                if oid < startOID:
                    continue
                if stopOID and oid >= stopOID:
                    continue
                if oid in contexts[context]:
                    if value != contexts[context][oid]:
                        stats['snapshots taken'] +=1
                else:
                    contexts[context][oid] = [], []
                contexts[context][oid][0].append(t - private['basetime'])
                contexts[context][oid][1].append(value)
                stats['OIDs seen'] += 1

开发者ID:woodyle，项目名称:snmpsim，代码行数:48，代码来源:pcap2dev.py

示例15: cbFun

def cbFun(transportDispatcher, transportDomain, transportAddress, wholeMsg):
	while wholeMsg:
		msgVer = int(api.decodeMessageVersion(wholeMsg))
		if api.protoModules.has_key(msgVer):
			pMod = api.protoModules[msgVer]
		else:
			print 'Unsupported SNMP version %s' % msgVer
			return

		reqMsg, wholeMsg = decoder.decode( wholeMsg, asn1Spec=pMod.Message())

		#print 'Trap from %s[%s]:' % transportAddress

		reqPDU = pMod.apiMessage.getPDU(reqMsg)
		if reqPDU.isSameTypeWith(pMod.TrapPDU()):
			if msgVer == api.protoVersion1:
				agent		= pMod.apiTrapPDU.getAgentAddr(reqPDU).prettyPrint()
				enterprise	= str(pMod.apiTrapPDU.getEnterprise(reqPDU))
				gtrap		= str(pMod.apiTrapPDU.getGenericTrap(reqPDU))
				strap		= str(pMod.apiTrapPDU.getSpecificTrap(reqPDU))
				varBinds 	= pMod.apiTrapPDU.getVarBindList(reqPDU)
				timestamp 	= pMod.apiTrapPDU.getTimeStamp(reqPDU)

				trap_oid = enterprise + '.0.' + strap

				if enterprise in snmp2amqp_conf.blacklist_enterprise:
					logger.debug("Blacklist enterprise: '%s'." % enterprise)
					return wholeMsg

				if trap_oid in snmp2amqp_conf.blacklist_trap_oid:
					logger.debug("Blacklist trap: '%s'." % trap_oid)
					return wholeMsg

				mib = None
				try:
					mib = mibs[enterprise]
				except:	
					logger.warning("Unknown trap from '%s': %s" % (agent, trap_oid))
					logger.warning(" + Unknown enterprise '%s'" % enterprise)
					#if varBinds:
					#	for oid, components in varBinds:
					#		print "  + ", oid

				if mib:
					try:
						parse_trap(mib, trap_oid, agent, varBinds)
					except Exception, err:
						logger.error("Impossible to parse trap: %s" % err)

开发者ID:EzanLTD，项目名称:canopsis，代码行数:48，代码来源:snmp2amqp.py

示例16: cbFun

 def cbFun(self, transportDispatcher, transportDomain, transportAddress, wholeMsg):
     mibInstr = self._mibInstr
     mibInstrIdx = self._mibInstrIdx
     while wholeMsg:
         msgVer = api.decodeMessageVersion(wholeMsg)
         if msgVer in api.protoModules:
             pMod = api.protoModules[msgVer]
         else:
             return
         reqMsg, wholeMsg = decoder.decode(wholeMsg, asn1Spec=pMod.Message())
         rspMsg = pMod.apiMessage.getResponse(reqMsg)
         rspPDU = pMod.apiMessage.getPDU(rspMsg)
         reqPDU = pMod.apiMessage.getPDU(reqMsg)
         varBinds = []
         errorIndex = -1
         # GETNEXT PDU
         if reqPDU.isSameTypeWith(pMod.GetNextRequestPDU()):
             # Produce response var-binds
             errorIndex = -1
             for oid, val in pMod.apiPDU.getVarBinds(reqPDU):
                 errorIndex = errorIndex + 1
                 # Search next OID to report
                 nextIdx = bisect.bisect(mibInstr, oid)
                 if nextIdx == len(mibInstr):
                     # Out of MIB
                     pMod.apiPDU.setEndOfMibError(rspPDU, errorIndex)
                 else:
                     # Report value if OID is found
                     varBinds.append((mibInstr[nextIdx].name, mibInstr[nextIdx](msgVer)))
         elif reqPDU.isSameTypeWith(pMod.GetRequestPDU()):
             for oid, val in pMod.apiPDU.getVarBinds(reqPDU):
                 if oid in mibInstrIdx:
                     varBinds.append((oid, mibInstrIdx[oid](msgVer)))
                 else:
                     # No such instance
                     try:
                         pMod.apiPDU.setNoSuchInstanceError(rspPDU, errorIndex)
                     except IndexError:
                         pass
                     varBinds = pMod.apiPDU.getVarBinds(reqPDU)
                     break
         else:
             # Report unsupported request type
             pMod.apiPDU.setErrorStatus(rspPDU, "genErr")
         pMod.apiPDU.setVarBinds(rspPDU, varBinds)
         transportDispatcher.sendMessage(encoder.encode(rspMsg), transportDomain, transportAddress)
     return wholeMsg

开发者ID:blackwithwhite666，项目名称:snmp_orm，代码行数:47，代码来源:agent.py

示例17: cbFun

def cbFun(transportDispatcher, transportDomain, transportAddress, wholeMsg):#处理Trap信息的函数
    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#打印发送TRAP的源信息
            )
        )
        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.getVarBindList(reqPDU)
            else:
                varBinds = pMod.apiPDU.getVarBindList(reqPDU)
            print('Var-binds:')
            for oid, val in varBinds:
                print('%s = %s' % (oid.prettyPrint(), val.prettyPrint()))#打印具体的Trap信息内容
    return wholeMsg

开发者ID:ye66666，项目名称:PyQYT，代码行数:45，代码来源:trap.py

示例18: _trap_receiver_cb

    def _trap_receiver_cb(transport, domain, sock, msg):
        if decodeMessageVersion(msg) != protoVersion2c:
            raise RuntimeError('Only SNMP v2c traps are supported.')

        req, msg = decoder.decode(msg, asn1Spec=v2c.Message())
        pdu = v2c.apiMessage.getPDU(req)

        # ignore any non trap PDUs
        if not pdu.isSameTypeWith(v2c.TrapPDU()):
            return

        if trap_filter(domain, sock, pdu):
            raise StopListener()


        # Stop the receiver if the trap we are looking for was received.
        if False:
            raise StopListener()

开发者ID:njustbxh，项目名称:robotframework-snmplibrary，代码行数:18，代码来源:traps.py

示例19: _callback

    def _callback(self, transport_dispatcher, transport_domain, transport_address, whole_msg):
        try:
            while whole_msg:
                msg_version = int(api.decodeMessageVersion(whole_msg))
                if msg_version not in api.protoModules:
                    logging.info('Unsupported SNMP version {} {}'.format(msg_version, transport_address[0]))
                    return

                proto_module = api.protoModules[msg_version]

                request_msg, whole_msg = decoder.decode(whole_msg, asn1Spec=proto_module.Message(),)
                request_pdu = proto_module.apiMessage.getPDU(request_msg)
                if transport_address[0] == '0.0.0.0':
                    logging.info('Broadcast snmptrap ignored')
                    return
                if request_pdu.isSameTypeWith(proto_module.TrapPDU()):
                    self._extract_and_process_trap(proto_module, request_pdu, transport_address)
        except Exception as exc:
            logging.error('Error snmptrap: {}  {}'.format(exc, exc.__class__.__name__))

开发者ID:aleasoluciones，项目名称:infsnmp，代码行数:19，代码来源:traps.py

示例20: _cbHandler

    def _cbHandler(self, transportDispatcher, transportDomain, \
                  transportAddress, wholeMsg):
        '''
        ' 回调处理接收信息
        ' raise Exception: trap消息处理失败时抛出
        '''
        logger.info('enter the _cbHandler function')
        while wholeMsg:
            # 提取为checkVersion, 返回pMod
            msgVer = api.decodeMessageVersion(wholeMsg)
            if msgVer in api.protoModules:
                pMod = api.protoModules[msgVer]
            else:
                return
            reqMsg, wholeMsg = decoder.decode(
                wholeMsg, asn1Spec=pMod.Message(),
                )
            reqPDU = pMod.apiMessage.getPDU(reqMsg)

            if reqPDU.isSameTypeWith(pMod.TrapPDU()):
                # 获取绑定值
                if msgVer == api.protoVersion1:
                    agentip = pMod.apiTrapPDU.getAgentAddr(reqPDU).prettyPrint()
                    varBinds = pMod.apiTrapPDU.getVarBindList(reqPDU)
                else:
                    agentip = transportAddress[0]
                    varBinds = pMod.apiPDU.getVarBindList(reqPDU)
                    
            try:
                # 构造处理器处理trap消息
                handler = HandlerFactory.createHandler(agentip, varBinds, self._configdata)
                if not handler is None:
                    logger.info('begin handler the trap')
                    handler.handle()
                else:
                    logger.info("do not surpport the alarm ")
            except Exception, err:
                print err
                logger.info("handle the host[%s] alarm exception[%s]" % (agentip, err))

开发者ID:eSDK，项目名称:esdk_Nagios，代码行数:39，代码来源:Trap.py

注：本文中的pysnmp.proto.api.decodeMessageVersion函数示例由纯净天空整理自Github/MSDocs等源码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目

鲜花

握手

雷人

路过

鸡蛋

该文章已有0人参与评论

请发表评论

全部评论

专题导读

More+

10-27 六六分期app的软件客服如何联系？(六六分期

11-06 可心卡盟:win10系统火狐flash插件崩溃怎么

11-06 亲亲特价:怎么删除回收站图标

11-06 济南大学虚拟社区:鲁大师节能降温的具体办

11-06 xlueops.exe:无线网络安装向导

11-06 女斗合众国:win7系统cf与主机连接不稳定怎

11-06 0xc000022-[cf烟雾头]cf怎么调烟雾头

11-06 qizideyouhuo:应用程序无法正常启动0xc0000

11-06 ipz-185:win7系统vcf文件怎么打开

11-06 傻哥蹦迪:win10系统s4怎么打开usb调试

11-06 八神浩树gtaste:回收站清空了怎么恢复

11-06 妖尾之黑色守护:win10系统电脑没有1440x900

11-06 校园至尊魔王小说:win7系统浏览网页时字体

11-06 女斗合众国:win10系统访问共享文件夹提示请

11-06 tokyo hot n0654:恢复win7系统默认字体一招

11-06 雨酷仙境:设置win7系统转移临时文件夹腾出

11-06 阿穆纳伊之杖:win7系统开始菜单在右边还原

11-06 tunespotting:win10系统火狐flash插件总是

11-06 甘尔葛分析师：计谋网站seo关键词暴涨有什

11-06 蔡贵霖: 计谋网站seo关键词暴涨有什么秘密

11-06 博益网首页:ao3网页版进入不了解决方法

11-06 漏斗子专栏: 网站数据分析小白易懂精华篇

11-06 见证双虹怎么做:win7系统开启telnet命令的

11-06 颾狐蝶蜋:系统资源不足无法完成请求的服务

11-06 国光中学校歌:提交网站到alexa查询详细步骤

11-06 西安有情天:静态网页和动态网页的区别

11-06 红木雅尚斋:外部链接构造对网站的好处

11-06 前官礼遇：防止域名劫持–增强域安全性的10

11-06 密传二转答案: 中文分词算法有哪些

11-06 金泉家园邮编:百度快照劫持的表现及应对方

Python snpreader.Bed类代码示例发布时间：2022-05-26

Python config.addVacmUser函数代码示例发布时间：2022-05-26

Python util.grid_equal函数代码示例

1 Python 入门教程

Python入门教程 Python 是一种解释型、面向对象、动态数据类型的高级程序设计语言。 P

阅读：13786|2022-01-22

2 Python wikiutil.getFrontPage函数代码示例

Python wikiutil.getFrontPage函数代码示例

阅读：10177|2022-05-24

3 Python 简介

Python 简介 Python 是一个高层次的结合了解释性、编译性、互动性和面向对象的脚本

阅读：4074|2022-01-22

4 Python tests.group函数代码示例

Python tests.group函数代码示例

阅读：4039|2022-05-27

5 Python util.check_if_user_has_permission

Python util.check_if_user_has_permission函数代码示例

阅读：3831|2022-05-27

6 Python 操练实例98

Python 练习实例98 Python 100例题目：从键盘输入一个字符串，将小写字母全部转换成大

阅读：3508|2022-01-22

7 Python 环境搭建

Python 环境搭建本章节我们将向大家介绍如何在本地搭建 Python 开发环境。 Py

阅读：3029|2022-01-22

8 Python output.darkgreen函数代码示例

Python output.darkgreen函数代码示例

阅读：2645|2022-05-25

9 Python 基础语法

Python 基础语法 Python 语言与 Perl，C 和 Java 等语言有许多相似之处。但是，也

阅读：2635|2022-01-22

10 Python 中文编码

Python 中文编码前面章节中我们已经学会了如何用 Python 输出 Hello, World!，英文没

阅读：2293|2022-01-22

客服电话

电子邮件

Python api.decodeMessageVersion函数代码示例

示例1: cbFun

示例2: receive_message

示例3: cbFun

示例4: cbFun

示例5: cbFun

示例6: cbFun

示例7: onSnmpMessage

示例8: newFn

示例9: _trap_receiver_cb

示例10: trapCallback

示例11: cbFun

示例12: _on_trap

示例13: unpack_msg

示例14: handleSnmpMessage

示例15: cbFun

示例16: cbFun

示例17: cbFun

示例18: _trap_receiver_cb

示例19: _callback

示例20: _cbHandler

请发表评论

全部评论

上一篇：

下一篇：

Python util.grid_equal函数代码示例

Python util.get_worker_name函数代码示例

Python util.get_webmention_target函数代

Python util.get_uuid函数代码示例

Python util.get_type_by_name函数代码示例

Python util.grid_equal函数代码示例

Python util.get_worker_name函数代码示例

Python util.get_webmention_target函数代

Python util.get_uuid函数代码示例

Python util.get_type_by_name函数代码示例

Python util.get_stdout函数代码示例

关于我们

产品与服务

解决方案

139-2527-9053