diff options
Diffstat (limited to 'examples/v3arch/asyncore/agent/cmdrsp/v2c-custom-scalar-mib-objects.py')
-rw-r--r-- | examples/v3arch/asyncore/agent/cmdrsp/v2c-custom-scalar-mib-objects.py | 82 |
1 files changed, 82 insertions, 0 deletions
diff --git a/examples/v3arch/asyncore/agent/cmdrsp/v2c-custom-scalar-mib-objects.py b/examples/v3arch/asyncore/agent/cmdrsp/v2c-custom-scalar-mib-objects.py new file mode 100644 index 0000000..196ee9c --- /dev/null +++ b/examples/v3arch/asyncore/agent/cmdrsp/v2c-custom-scalar-mib-objects.py @@ -0,0 +1,82 @@ +""" +Implementing scalar MIB objects ++++++++++++++++++++++++++++++++ + +Listen and respond to SNMP GET/SET/GETNEXT/GETBULK queries with +the following options: + +* SNMPv2c +* with SNMP community "public" +* serving custom Managed Object Instance defined within this script +* allow read access only to the subtree where the custom MIB object resides +* over IPv4/UDP, listening at 127.0.0.1:161 + +The following Net-SNMP commands will walk this Agent: + +| $ snmpwalk -v2c -c public 127.0.0.1 .1.3.6 + +"""# +import sys +from pysnmp.entity import engine, config +from pysnmp.entity.rfc3413 import cmdrsp, context +from pysnmp.carrier.asyncore.dgram import udp +from pysnmp.proto.api import v2c + +# Create SNMP engine +snmpEngine = engine.SnmpEngine() + +# Transport setup + +# UDP over IPv4 +config.addTransport( + snmpEngine, + udp.domainName, + udp.UdpTransport().openServerMode(('127.0.0.1', 161)) +) + +# SNMPv2c setup + +# SecurityName <-> CommunityName mapping. +config.addV1System(snmpEngine, 'my-area', 'public') + +# Allow read MIB access for this user / securityModels at VACM +config.addVacmUser(snmpEngine, 2, 'my-area', 'noAuthNoPriv', (1,3,6,5)) + +# Create an SNMP context +snmpContext = context.SnmpContext(snmpEngine) + +# --- create custom Managed Object Instance --- + +mibBuilder = snmpContext.getMibInstrum().getMibBuilder() + +MibScalar, MibScalarInstance = mibBuilder.importSymbols( + 'SNMPv2-SMI', 'MibScalar', 'MibScalarInstance' +) + +class MyStaticMibScalarInstance(MibScalarInstance): + def getValue(self, name, idx): + return self.getSyntax().clone( + 'Python %s running on a %s platform' % (sys.version, sys.platform) + ) + +mibBuilder.exportSymbols( + '__MY_MIB', MibScalar((1,3,6,5,1), v2c.OctetString()), + MyStaticMibScalarInstance((1,3,6,5,1), (0,), v2c.OctetString()) +) + +# --- end of Managed Object Instance initialization ---- + +# Register SNMP Applications at the SNMP engine for particular SNMP context +cmdrsp.GetCommandResponder(snmpEngine, snmpContext) +cmdrsp.NextCommandResponder(snmpEngine, snmpContext) +cmdrsp.BulkCommandResponder(snmpEngine, snmpContext) + +# Register an imaginary never-ending job to keep I/O dispatcher running forever +snmpEngine.transportDispatcher.jobStarted(1) + +# Run I/O dispatcher which would receive queries and send responses +try: + snmpEngine.transportDispatcher.runDispatcher() +except: + snmpEngine.transportDispatcher.closeDispatcher() + raise |