From fd73f0290bdc29a44b8464e0fbec91232360202a Mon Sep 17 00:00:00 2001 From: elie Date: Mon, 1 Jun 2015 18:11:22 +0000 Subject: initial revision --- .../v3arch/agent/ntforg/trap-v2c-custom-pdu.py | 84 ++++++++++++++++++++++ 1 file changed, 84 insertions(+) create mode 100644 examples/v3arch/agent/ntforg/trap-v2c-custom-pdu.py diff --git a/examples/v3arch/agent/ntforg/trap-v2c-custom-pdu.py b/examples/v3arch/agent/ntforg/trap-v2c-custom-pdu.py new file mode 100644 index 0000000..115022c --- /dev/null +++ b/examples/v3arch/agent/ntforg/trap-v2c-custom-pdu.py @@ -0,0 +1,84 @@ +# +# Notification Originator +# +# Send SNMP TRAP notification using the following options: +# +# * SNMPv2c +# * with community name 'public' +# * over IPv4/UDP +# * send TRAP notification +# * to a Manager at 127.0.0.1:162 +# * initialize TRAP PDU with the following var-binds: +# 1.3.6.1.2.1.1.3.0 = 123 +# 1.3.6.1.6.3.1.1.4.1.0 = 1.3.6.1.6.3.1.1.5.1 +# +from pysnmp.entity import engine, config +from pysnmp.carrier.asynsock.dgram import udp +from pysnmp.entity.rfc3413 import ntforg +from pysnmp.proto.api import v2c + +# Create SNMP engine instance +snmpEngine = engine.SnmpEngine() + +# SecurityName <-> CommunityName mapping +config.addV1System(snmpEngine, 'my-area', 'public') + +# Specify security settings per SecurityName (SNMPv2c -> 1) +config.addTargetParams(snmpEngine, 'my-creds', 'my-area', 'noAuthNoPriv', 1) + +# Setup transport endpoint and bind it with security settings yielding +# a target name +config.addTransport( + snmpEngine, + udp.domainName, + udp.UdpSocketTransport().openClientMode() +) + +# Create named target +config.addTargetAddr( + snmpEngine, 'my-nms', + udp.domainName, ('127.0.0.1', 162), + 'my-creds' +) + +# *** SNMP engine configuration is complete by this line *** + +# Create SNMP v2c TRAP PDU with defaults +trapPDU = v2c.TrapPDU() +v2c.apiTrapPDU.setDefaults(trapPDU) + +# Set custom var-binds to TRAP PDU +v2c.apiTrapPDU.setVarBinds( + trapPDU, [ + # sysUpTime + ( v2c.ObjectIdentifier('1.3.6.1.2.1.1.3.0'), v2c.TimeTicks(123) ), + # snmpTrapPDU + ( (1,3,6,1,6,3,1,1,4,1,0), v2c.ObjectIdentifier((1,3,6,1,6,3,1,1,5,1)) ) + ] +) + +# Create Notification Originator App instance. +ntfOrg = ntforg.NotificationOriginator() + +# Error/confirmation receiver +def cbFun(snmpEngine, sendRequestHandle, errorIndication, + errorStatus, errorIndex, varBinds, cbCtx): + print('Notification %s, status - %s' % ( + sendRequestHandle, errorIndication and errorIndication or 'delivered' + ) + ) + +# Build and submit notification message to dispatcher +sendRequestHandle = ntfOrg.sendPdu( + snmpEngine, + # Notification targets + 'my-nms', # target address + None, '', # contextEngineId, contextName + trapPDU, + cbFun +) + +print('Notification %s is scheduled to be sent' % sendRequestHandle) + +# Run I/O dispatcher which would send pending message and process response +snmpEngine.transportDispatcher.runDispatcher() -- cgit v1.2.1