org.thales.punch.libraries.storm.spout

Class SnmpInput

java.lang.Object

org.apache.storm.topology.base.BaseComponent

org.apache.storm.topology.base.BaseRichSpout

org.thales.punch.libraries.storm.api.BaseInputNode

org.thales.punch.libraries.storm.spout.AbstractSocketInput<T>

org.thales.punch.libraries.storm.spout.SyslogInput<String>

org.thales.punch.libraries.storm.spout.SnmpInput

All Implemented Interfaces:

Serializable, org.apache.storm.spout.ISpout, org.apache.storm.topology.IComponent, org.apache.storm.topology.IRichSpout, ISyslogReceiver<String>

public class SnmpInput
extends SyslogInput<String>

The SNMP spout is able to receive SNMP Traps over UDP It decodes the SNMP Traps messages into a JSON format - cf. SnmpServerImpl.jsonFromPdu(org.snmp4j.PDU, org.snmp4j.smi.Address, byte[])

Its internal server working (UDP pro) shares the same implementation as a SyslogInput.

But the listening settings are only

 "listen" :
            {
               "host" : "bind.listening.ip.address",
               "port" : 162
            }
 

and SSL settings are ignored.

You can test this by using :

 sudo snmptrap -v 1 -c public localhost:9901 1.2.3.4 localhost 2 0 "" 1.2.3.4.5 s "18000" 1.2.4.6.8 i 42
 

This shoulds return something like this :

 {
 "traps": {
   "_ppf_local_host": "0.0.0.0",
   "_ppf_remote_port": 51254,
   "trap": {
     "enterprise_oid": "1.2.3.4",
     "generic_trap_id": 2,
     "pdu_type": -92,
     "request_id": 0,
     "security_name": "public",
     "snmp_version": "v1",
     "source_agent_address": "127.0.0.1",
     "specific_trap_id": 0,
     "uptime_in_cs": 62161531,
     "variables": [
       {
         "oid": "1.2.3.4.5",
         "type": "STRING",
         "value": "18000"
       },
       {
         "oid": "1.2.4.6.8",
         "type": "INT32",
         "value": 42
       }
     ]
   },
   "_ppf_id": "XFhRXW0B8Tvey3mpctsn",
   "_ppf_local_port": 9901,
   "_ppf_timestamp": 1569228681767,
   "_ppf_remote_host": "127.0.0.1"
 }

 

Author:

cedric

See Also:

Serialized Form

Field Summary

Fields inherited from class org.thales.punch.libraries.storm.spout.AbstractSocketInput

charset

Fields inherited from class org.thales.punch.libraries.storm.api.BaseInputNode

collector, exitCondition, latencyRecordSender, loadController, metricContext, myself, nodeSettings

Constructor Summary

Constructors

Constructor and Description
SnmpInput(org.thales.punch.libraries.storm.api.NodeSettings spoutConfig)

Method Summary

Methods inherited from class org.thales.punch.libraries.storm.spout.SyslogInput

close, fail, nextTuple, onReceive, open, registerNextTupleCallback

Methods inherited from class org.thales.punch.libraries.storm.spout.AbstractSocketInput

ack, getSocketHostAddress

Methods inherited from class org.thales.punch.libraries.storm.api.BaseInputNode

deactivate, declareOutputFields, getPublishedStreams, regulate, sendLatencyRecord

Methods inherited from class org.apache.storm.topology.base.BaseRichSpout

activate

Methods inherited from class org.apache.storm.topology.base.BaseComponent

getComponentConfiguration

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.storm.spout.ISpout

activate

Methods inherited from interface org.apache.storm.topology.IComponent

getComponentConfiguration

Constructor Detail

SnmpInput

public SnmpInput(org.thales.punch.libraries.storm.api.NodeSettings spoutConfig)

Parameters:

spoutConfig - - a SyslogSpout compatible config, but with snmp codec set by the SnmpSpoutFactory.