syslogLevel = logging.INFO
mailLevel = logging.CRITICAL # must be "larger" than syslog level!
mailAddress = ['post+tuer'+'@'+'ralfj.de', 'vorstand@lists.hacksaar.de']
+printLevel = logging.DEBUG
# Mail logging handler
def sendeMail(subject, text, receivers, sender='sphinx@hacksaar.de', replyTo=None):
- if not isinstance(type(receivers), list): receivers = [receivers]
+ assert isinstance(receivers, list)
+ if not len(receivers): return # nothing to do
# construct content
msg = email.mime.text.MIMEText(text.encode('UTF-8'), 'plain', 'UTF-8')
msg['Subject'] = subject
class Logger:
def __init__ (self):
self.syslog = logging.getLogger("tuerd")
- self.syslog.setLevel(syslogLevel)
+ self.syslog.setLevel(logging.DEBUG)
self.syslog.addHandler(logging.handlers.SysLogHandler(address = '/dev/log',
facility = logging.handlers.SysLogHandler.LOG_LOCAL0))
def _log (self, lvl, what):
thestr = "%s[%d]: %s" % ("tuerd", os.getpid(), what)
# console log
- print(thestr)
+ if lvl >= printLevel:
+ print(thestr)
# syslog
- self.syslog.log(lvl, thestr)
+ if lvl >= syslogLevel:
+ self.syslog.log(lvl, thestr)
# mail log
- if lvl >= mailLevel:
+ if lvl >= mailLevel and mailAddress is not None:
sendeMail('Kritischer Türfehler', what, mailAddress)
def debug(self, what):
logger = Logger()
+# run a Python command asynchronously
+def fire_and_forget(f):
+ def _fire_and_forget():
+ try:
+ f()
+ except Exception as e:
+ logger.critical("fire_and_forget: Got exception out of callback: %s" % str(e))
+ logger.debug(traceback.format_exc())
+ t = threading.Thread(target=_fire_and_forget)
+ t.start()
+
# run a command asynchronously and log the return value if not 0
# prefix must be a string identifying the code position where the call came from
-def fire_and_forget (cmd, log, prefix):
- def _fire_and_forget ():
+def fire_and_forget_cmd (cmd, log, prefix):
+ def _fire_and_forget_cmd ():
with open("/dev/null", "w") as fnull:
retcode = subprocess.call(cmd, stdout=fnull, stderr=fnull)
if retcode is not 0:
logger.error("%sReturn code %d at command: %s" % (prefix,retcode,str(cmd)))
- t = threading.Thread(target=_fire_and_forget)
- t.start()
+ fire_and_forget(_fire_and_forget_cmd)
# Threaded callback class
class ThreadFunction():