From b4c39e0ea54791d3c56d9d42b1368bd3dbce5be3 Mon Sep 17 00:00:00 2001
From: Jack the Ripper <jack@x4.2.localnet.cc>
Date: Sun, 15 Nov 2015 10:50:45 +0100
Subject: - workaround for timeout error - improved logging - disabled
 apscheduler in support of a simple sleep()

---
 usv_scheduler.py | 33 +++++++++++++++++++++++++++------
 1 file changed, 27 insertions(+), 6 deletions(-)

(limited to 'usv_scheduler.py')

diff --git a/usv_scheduler.py b/usv_scheduler.py
index 1dccc5f..09bcf2b 100755
--- a/usv_scheduler.py
+++ b/usv_scheduler.py
@@ -1,5 +1,7 @@
 #!/usr/bin/env python3
 
+from time import sleep
+
 from apscheduler.schedulers.background import BlockingScheduler
 from usv_driver import Usv
 from influxdb import InfluxDBClient
@@ -10,7 +12,6 @@ import logging
 
 INTERVAL=14 # execution takes about 6s
 
-logging.basicConfig(level=logging.INFO)
 
 parser = argparse.ArgumentParser()
 parser.add_argument('--host', help='Database host', default='localhost')
@@ -21,16 +22,26 @@ parser.add_argument('--baud', help='Serial baudrate', default='600')
 parser.add_argument('--param', help='Parameter JSON file', default='./usv_param.json')
 args = parser.parse_args(sys.argv[1:])
 
-scheduler = BlockingScheduler(timezone="Europe/Berlin")
+#scheduler = BlockingScheduler(timezone="Europe/Berlin")
 
 db_client = InfluxDBClient(host=args.host,
         port=args.port,
         database=args.db)
 
+logging.basicConfig(level=logging.ERROR, filename='log/usv_scheduler.log')
+
 usv = Usv(args.serial, int(args.baud), args.param)
+usv_lock = False
 
-@scheduler.scheduled_job('interval', seconds=INTERVAL)
+#@scheduler.scheduled_job('interval', seconds=INTERVAL)
 def timed_job():
+    global usv_lock
+
+    if usv_lock:
+        logging.info("JOB CURRENTLY LOCKED")
+        return
+
+    usv_lock = True
     parameters = usv.get_parameters()
     data = []
     for name in parameters:
@@ -42,8 +53,18 @@ def timed_job():
                 },
             'fields': {'value': parameters[name]}
             });
-        logging.info("insert: %s: %s" % (name, parameters[name]))
+    print("insert: %s" % ",".join("%s=%s" % \
+            (name,parameters[name]) for name in parameters))
     
-    db_client.write_points(data)
+    try:
+        db_client.write_points(data)
+    except Exception as e:
+        logging.error("%s" % e)
+
+    usv_lock = False
+
+while True:
+    timed_job()
+    sleep(24)
 
-scheduler.start()
+#scheduler.start()
-- 
cgit v1.2.1