Create cdr_parser.py

Author: slashdoom

cdr_parser.py

@@ -0,0 +1,52 @@
+import logging
+import time
+
+from daemon import runner
+from mod_cdr_main import (
+  initial_program_setup,
+  do_main_program,
+  program_cleanup,
+  reload_program_config,
+  )
+
+class App():
+    
+  def __init__(self):
+    self.stdin_path = '/dev/null'
+    self.stdout_path = '/dev/tty'
+    self.stderr_path = '/dev/tty'
+    self.pidfile_path =  '/var/run/cdr_parser.pid'
+    self.pidfile_timeout = 5
+
+  def run(self):
+    logger.info("cdr_parser started")
+
+    while True:
+      # Call Main Program
+      do_main_program()
+      
+app = App()
+
+logger = logging.getLogger(__name__)
+logger.setLevel(logging.DEBUG)
+
+# Logger Console Handler
+ch = logging.StreamHandler() # StreamHandler logs to console
+ch.setLevel(logging.DEBUG)
+ch_format = logging.Formatter('%(asctime)s - %(message)s')
+ch.setFormatter(ch_format)
+logger.addHandler(ch)
+
+# Logger File Handler
+fh = logging.FileHandler('/var/log/cdr_parser/{0}.log'.format(__name__))
+fh.setLevel(logging.INFO)
+fh_format = logging.Formatter('%(asctime)s - %(name)s - %(levelname)-8s - %(message)s')
+fh.setFormatter(fh_format)
+logger.addHandler(fh)
+
+daemon_runner = runner.DaemonRunner(app)
+# Don't close logging files during daemonization
+daemon_runner.daemon_context.files_preserve=[fh.stream]
+daemon_runner.do_action()
+
+logger.info("cdr_parser stopped")