diff options
Diffstat (limited to 'examples/hlapi/v3arch/asyncio/manager')
4 files changed, 38 insertions, 14 deletions
diff --git a/examples/hlapi/v3arch/asyncio/manager/cmdgen/getbulk-to-eom.py b/examples/hlapi/v3arch/asyncio/manager/cmdgen/getbulk-to-eom.py index c60d6e12..aa6bf441 100644 --- a/examples/hlapi/v3arch/asyncio/manager/cmdgen/getbulk-to-eom.py +++ b/examples/hlapi/v3arch/asyncio/manager/cmdgen/getbulk-to-eom.py @@ -23,22 +23,25 @@ from pysnmp.hlapi.v3arch.asyncio import * @asyncio.coroutine def run(varBinds): + snmpEngine = SnmpEngine() + while True: - (errorIndication, - errorStatus, - errorIndex, - varBindTable) = yield from bulkCmd( + iterator = bulkCmd( snmpEngine, UsmUserData('usr-none-none'), UdpTransportTarget(('demo.snmplabs.com', 161)), ContextData(), 0, 50, - *varBinds) + *varBinds + ) + + errorIndication, errorStatus, errorIndex, varBindTable = yield from iterator if errorIndication: print(errorIndication) break + elif errorStatus: print('%s at %s' % ( errorStatus.prettyPrint(), diff --git a/examples/hlapi/v3arch/asyncio/manager/cmdgen/multiple-concurrent-queries-over-ipv4-and-ipv6.py b/examples/hlapi/v3arch/asyncio/manager/cmdgen/multiple-concurrent-queries-over-ipv4-and-ipv6.py index a1b5d9a0..5f3c78e7 100644 --- a/examples/hlapi/v3arch/asyncio/manager/cmdgen/multiple-concurrent-queries-over-ipv4-and-ipv6.py +++ b/examples/hlapi/v3arch/asyncio/manager/cmdgen/multiple-concurrent-queries-over-ipv4-and-ipv6.py @@ -23,7 +23,8 @@ from pysnmp.hlapi.v3arch.asyncio import * @asyncio.coroutine def getone(snmpEngine, hostname): - errorIndication, errorStatus, errorIndex, varBinds = yield from getCmd( + + iterator = getCmd( snmpEngine, CommunityData('public'), UdpTransportTarget(hostname), @@ -31,8 +32,11 @@ def getone(snmpEngine, hostname): ObjectType(ObjectIdentity('SNMPv2-MIB', 'sysDescr', 0)) ) + errorIndication, errorStatus, errorIndex, varBinds = yield from iterator + if errorIndication: print(errorIndication) + elif errorStatus: print('%s at %s' % ( errorStatus.prettyPrint(), @@ -48,7 +52,9 @@ snmpEngine = SnmpEngine() loop = asyncio.get_event_loop() loop.run_until_complete( - asyncio.wait([getone(snmpEngine, ('demo.snmplabs.com', 1161)), - getone(snmpEngine, ('demo.snmplabs.com', 2161)), - getone(snmpEngine, ('demo.snmplabs.com', 3161))]) + asyncio.wait( + [getone(snmpEngine, ('demo.snmplabs.com', 1161)), + getone(snmpEngine, ('demo.snmplabs.com', 2161)), + getone(snmpEngine, ('demo.snmplabs.com', 3161))] + ) ) diff --git a/examples/hlapi/v3arch/asyncio/manager/cmdgen/multiple-sequential-queries.py b/examples/hlapi/v3arch/asyncio/manager/cmdgen/multiple-sequential-queries.py index d546870d..626661d0 100644 --- a/examples/hlapi/v3arch/asyncio/manager/cmdgen/multiple-sequential-queries.py +++ b/examples/hlapi/v3arch/asyncio/manager/cmdgen/multiple-sequential-queries.py @@ -23,7 +23,8 @@ from pysnmp.hlapi.v3arch.asyncio import * @asyncio.coroutine def getone(snmpEngine, hostname): - errorIndication, errorStatus, errorIndex, varBinds = yield from getCmd( + + iterator = getCmd( snmpEngine, CommunityData('public'), UdpTransportTarget(hostname), @@ -31,8 +32,11 @@ def getone(snmpEngine, hostname): ObjectType(ObjectIdentity('SNMPv2-MIB', 'sysDescr', 0)) ) + errorIndication, errorStatus, errorIndex, varBinds = yield from iterator + if errorIndication: print(errorIndication) + elif errorStatus: print('%s at %s' % ( errorStatus.prettyPrint(), @@ -53,6 +57,13 @@ def getall(snmpEngine, hostnames): snmpEngine = SnmpEngine() loop = asyncio.get_event_loop() -loop.run_until_complete(getall(snmpEngine, [('demo.snmplabs.com', 1161), - ('demo.snmplabs.com', 2161), - ('demo.snmplabs.com', 3161)])) + +loop.run_until_complete( + getall( + snmpEngine, [ + ('demo.snmplabs.com', 1161), + ('demo.snmplabs.com', 2161), + ('demo.snmplabs.com', 3161) + ] + ) +) diff --git a/examples/hlapi/v3arch/asyncio/manager/cmdgen/v1-get.py b/examples/hlapi/v3arch/asyncio/manager/cmdgen/v1-get.py index f14a9f63..a7bf585a 100644 --- a/examples/hlapi/v3arch/asyncio/manager/cmdgen/v1-get.py +++ b/examples/hlapi/v3arch/asyncio/manager/cmdgen/v1-get.py @@ -22,7 +22,8 @@ from pysnmp.hlapi.v3arch.asyncio import * @asyncio.coroutine def run(): snmpEngine = SnmpEngine() - errorIndication, errorStatus, errorIndex, varBinds = yield from getCmd( + + iterator = getCmd( snmpEngine, CommunityData('public', mpModel=0), UdpTransportTarget(('demo.snmplabs.com', 161)), @@ -30,8 +31,11 @@ def run(): ObjectType(ObjectIdentity('SNMPv2-MIB', 'sysDescr', 0)) ) + errorIndication, errorStatus, errorIndex, varBinds = yield from iterator + if errorIndication: print(errorIndication) + elif errorStatus: print('%s at %s' % ( errorStatus.prettyPrint(), |