diff options
Diffstat (limited to 'examples/hlapi/v3arch/asyncio')
6 files changed, 53 insertions, 21 deletions
diff --git a/examples/hlapi/v3arch/asyncio/agent/ntforg/default-v1-trap.py b/examples/hlapi/v3arch/asyncio/agent/ntforg/default-v1-trap.py index 6a0fefda..41032e9b 100644 --- a/examples/hlapi/v3arch/asyncio/agent/ntforg/default-v1-trap.py +++ b/examples/hlapi/v3arch/asyncio/agent/ntforg/default-v1-trap.py @@ -26,8 +26,10 @@ from pysnmp.hlapi.v3arch.asyncio import * @asyncio.coroutine def run(): + snmpEngine = SnmpEngine() - errorIndication, errorStatus, errorIndex, varBinds = yield from sendNotification( + + iterator = sendNotification( snmpEngine, CommunityData('public', mpModel=0), UdpTransportTarget(('demo.snmplabs.com', 162)), @@ -43,6 +45,8 @@ def run(): ) ) + errorIndication, errorStatus, errorIndex, varBinds = yield from iterator + if errorIndication: print(errorIndication) diff --git a/examples/hlapi/v3arch/asyncio/agent/ntforg/multiple-notifications-at-once.py b/examples/hlapi/v3arch/asyncio/agent/ntforg/multiple-notifications-at-once.py index f1cae2b8..fbdb568c 100644 --- a/examples/hlapi/v3arch/asyncio/agent/ntforg/multiple-notifications-at-once.py +++ b/examples/hlapi/v3arch/asyncio/agent/ntforg/multiple-notifications-at-once.py @@ -29,10 +29,8 @@ from pysnmp.hlapi.v3arch.asyncio import * @asyncio.coroutine def sendone(snmpEngine, hostname, notifyType): - (errorIndication, - errorStatus, - errorIndex, - varBinds) = yield from sendNotification( + + iterator = sendNotification( snmpEngine, CommunityData('public', tag=hostname), UdpTransportTarget((hostname, 162), tagList=hostname), @@ -48,10 +46,14 @@ def sendone(snmpEngine, hostname, notifyType): ) ) + errorIndication, errorStatus, errorIndex, varBinds = yield from iterator + if errorIndication: print(errorIndication) + elif errorStatus: print('%s: at %s' % (errorStatus.prettyPrint(), errorIndex and varBinds[int(errorIndex) - 1][0] or '?')) + else: for varBind in varBinds: print(' = '.join([x.prettyPrint() for x in varBind])) @@ -61,6 +63,8 @@ snmpEngine = SnmpEngine() loop = asyncio.get_event_loop() loop.run_until_complete( - asyncio.wait([sendone(snmpEngine, 'demo.snmplabs.com', 'trap'), - sendone(snmpEngine, 'demo.snmplabs.com', 'inform')]) + asyncio.wait( + [sendone(snmpEngine, 'demo.snmplabs.com', 'trap'), + sendone(snmpEngine, 'demo.snmplabs.com', 'inform')] + ) ) 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(), |