Receiving Custom Key Value Events via SNMP¶
Purpose:¶
This application demonstrates how to configure WSO2 Streaming Integrator Tooling to receive snmp source via SNMP in keyvalue using custom mapping.
Prerequisites:¶
- Save this sample.
- Install snmp agent on your network node.
- for Linux can install snmpd / for windows it can be configured by 'windows features'.
- configure snmp agent ex:- community string, port, user access.
- If there is no syntax error, the following message is shown on the console:
-
- SNMP-get-request-app successfully deployed.
-
Executing the Sample:¶
- Start the Siddhi application by clicking on 'Run'.
- If the Siddhi application starts successfully, the following messages are shown on the console:
- SNMP-set-request-app - Started Successfully!
Viewing the Results:¶
See the output. Following message would be shown on the console.
INFO {io.siddhi.core.stream.output.sink.LogSink} - SNMP-get-request-app : logStream : Event{timestamp=1************, data=[1:28:33.05, [email protected]], isExpired=false}
INFO {io.siddhi.core.stream.output.sink.LogSink} - SNMP-get-request-app : logStream : Event{timestamp=1************, data=[1:28:38.05, [email protected]], isExpired=false}
@App:name("SNMPGetRequestApp")
@App:description('listening oid status from agent')
@source(type ='snmp',
@map(type='keyvalue', @attributes(sysUpTime= '1.3.6.1.2.1.1.3.0', sysContact = '1.3.6.1.2.1.1.4.0') ),
host ='127.0.0.1',
version = 'v1',
request.interval = '5000',
community = 'public',
agent.port = '2019',
oids='1.3.6.1.2.1.1.3.0, 1.3.6.1.2.1.1.4.0')
define stream inputStream(sysUpTime string, sysContact string);
@sink(type='log')
define stream logStream (sysUpTime string, sysContact string);
-- passthrough data in the inputStream to logStream
@info(name='query1')
from inputStream
select *
insert into logStream;
Top