blob: c70bffd436aefb1bb63bf3cf5b856f58602cafcc (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
|
#!/usr/bin/env python2
import sys,json,time
from snmp_users import snmp_users
import logging
import genericore as gen
MODULE_NAME='snmp_users'
log = logging.getLogger(MODULE_NAME)
PROTO_VERSION = 1
DESCRIPTION = 'performes statistical analysis against mails from stream'
# set up instances of needed modules
conf = gen.Configurator(PROTO_VERSION,DESCRIPTION)
amqp = gen.auto_amqp(MODULE_NAME)
s = snmp_users(MODULE_NAME) # the magic mail parsing class
conf.configure([amqp,s]) #set up parser and eval parsed stuff
# start network connections
amqp.create_connection()
log.info('Starting up snmp_users')
print ' Sending Messages in Intervals. To exit press CTRL+C'
try:
while True:
log.info("collecting data from network")
ret = s.collect()
data = { 'type' : 'snmp', 'subtype' : 0, 'data' : ret}
log.debug("writing data to queue : %s" % data)
amqp.publish(json.dumps(data))
time.sleep(s.repeat)
except Exception as e:
print "something happened :( " + str(e)
|
