feat: added SNMP v1/v3 support (#40)

* fix: fixed the default port for SNMP Agent

* feat: added SNMPv1/v3 support

* fix: lookup authKey and privKey from config.yaml

* fix: handle NoSuchInstance error for snmp v2c/v3

* fix: lookup authKey and privKey from config.yaml & double check translated metric data

* refactor: removed unused param - hec_config

* fix: added all other optional params for creating CommunityData and CommunityData

* feat: added capability to specify the Context Name for SNMP v3

* fix: changed to send out the results to SPLUNK HEC on the fly

* fix: added more options for AuthProtocols and PrivProtocols

* fix: typo

* fix: typo v2

* fix: keeping black module happy

Co-authored-by: Mayur Pipaliya <[email protected]>

Author: lingy1028

splunk_connect_for_snmp_poller/manager/const.py

@@ -0,0 +1,23 @@
+from pysnmp.entity import config
+
+AuthProtocolMap = {
+    "MD5": config.usmHMACMD5AuthProtocol,
+    "SHA": config.usmHMACSHAAuthProtocol,
+    "SHA224": config.usmHMAC128SHA224AuthProtocol,
+    "SHA256": config.usmHMAC192SHA256AuthProtocol,
+    "SHA384": config.usmHMAC256SHA384AuthProtocol,
+    "SHA512": config.usmHMAC384SHA512AuthProtocol,
+    "NONE": config.usmNoAuthProtocol,
+}
+
+PrivProtocolMap = {
+    "DES": config.usmDESPrivProtocol,
+    "3DES": config.usm3DESEDEPrivProtocol,
+    "AES": config.usmAesCfb128Protocol,
+    "AES128": config.usmAesCfb128Protocol,
+    "AES192": config.usmAesCfb192Protocol,
+    "AES192BLMT": config.usmAesBlumenthalCfb192Protocol,
+    "AES256": config.usmAesCfb256Protocol,
+    "AES256BLMT": config.usmAesBlumenthalCfb256Protocol,
+    "NONE": config.usmNoPrivProtocol,
+}

splunk_connect_for_snmp_poller/manager/hec_sender.py

@@ -33,7 +33,6 @@ def post_data_to_splunk_hec(
 
 # TODO Discuss the format of event data payload
 def post_event_data(endpoint, host, variables_binds, index, one_time_flag=False):
-
     if "NoSuchInstance" in str(variables_binds):
         variables_binds = "error: " + str(variables_binds)
 
@@ -61,7 +60,6 @@ def post_event_data(endpoint, host, variables_binds, index, one_time_flag=False)
         logger.error(f"Connection error when sending data to HEC index - {index}: {e}")
 
 
-# TODO Discuss the format of metric data payload
 def post_metric_data(endpoint, host, variables_binds, index):
 
     json_val = json.loads(variables_binds)