import os.path
import platform
import pwd
-import socket
import subprocess
import struct
import time
def run(self):
current_time = time.time()
+ conn = None
try:
+ data = {}
+ for user in set(self.homedir_sizes.keys()) | \
+ set(self.lastlog_times.keys()):
+ data[user] = {
+ 'homedir': self.homedir_sizes.get(user, 0),
+ 'lastlog': self.lastlog_times.get(user, 0),
+ }
+
msg = {
'timestamp': current_time,
- 'data': self.homedir_sizes,
- 'host': socket.gethostname()
+ 'data': data,
+ 'host': platform.node(),
}
conn = Connection(conf=mq_conf)
conn.topic_send(config.topic,
exchange_name=config.exchange,
timeout=5)
except Exception, e:
- LOG.error("Error sending: %s" % e)
+ logging.error("Error sending: %s" % e)
finally:
if conn:
conn.close()
realname = pwd.getpwnam(username).pw_gecos.decode('utf-8').split(',', 1)[0]
except:
realname = username
- lastlog_time = self.lastlog_times[username]
+ lastlog_time = self.lastlog_times.get(username, 0)
days_ago = int( (current_time - lastlog_time) / 3600 / 24 )
kwargs = {
'hostname': platform.node(),