diff options
Diffstat (limited to 'usv_scheduler.py')
| -rwxr-xr-x | usv_scheduler.py | 33 |
1 files changed, 27 insertions, 6 deletions
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() |