summaryrefslogtreecommitdiff
path: root/usv_scheduler.py
diff options
context:
space:
mode:
Diffstat (limited to 'usv_scheduler.py')
-rwxr-xr-xusv_scheduler.py112
1 files changed, 0 insertions, 112 deletions
diff --git a/usv_scheduler.py b/usv_scheduler.py
deleted file mode 100755
index ff99818..0000000
--- a/usv_scheduler.py
+++ /dev/null
@@ -1,112 +0,0 @@
-#!/usr/bin/env python3
-<<<<<<< HEAD
-=======
-
-from time import sleep
-
->>>>>>> e3494d280fd6e2db591ea40c4365cdf18524fbdc
-from apscheduler.schedulers.background import BlockingScheduler
-from usv_driver import Usv
-from urllib.request import urlopen
-from pyinflux.client import Line
-
-import sys
-import argparse
-import logging
-from time import sleep
-
-<<<<<<< HEAD
-INTERVAL=24 # execution takes about 6s
-=======
-INTERVAL=14 # execution takes about 6s
-
->>>>>>> e3494d280fd6e2db591ea40c4365cdf18524fbdc
-
-parser = argparse.ArgumentParser()
-parser.add_argument('--url', help='URL')
-parser.add_argument('--serial', help='Serial port', default='/dev/ttyU0')
-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:])
-
-<<<<<<< HEAD
-logging.basicConfig(level=logging.DEBUG,
- filename='log/usv_scheduler.log',
- format='%(asctime)s %(message)s',
- datefmt='%Y-%m-%d %H:%M:%S')
-=======
-#scheduler = BlockingScheduler(timezone="Europe/Berlin")
-
-db_client = InfluxDBClient(host=args.host,
- port=args.port,
- database=args.db)
->>>>>>> e3494d280fd6e2db591ea40c4365cdf18524fbdc
-
-logging.basicConfig(level=logging.ERROR, filename='log/usv_scheduler.log')
-
-usv = Usv(args.serial, int(args.baud), args.param)
-<<<<<<< HEAD
-=======
-usv_lock = False
-
-#@scheduler.scheduled_job('interval', seconds=INTERVAL)
->>>>>>> e3494d280fd6e2db591ea40c4365cdf18524fbdc
-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:
-<<<<<<< HEAD
-
- line = Line('usv_parameters',
- {'name': name, 'id': 'LI????VA' },
- {'value': parameters[name]})
- data.append(line)
- logging.info("insert: {}".format(",".join(
- "{}={}".format(name,parameters[name]) for name in parameters)))
-
- try:
- post_data = '\n'.join(map(str, data))
- logging.info("urlopen begin: {}".format(post_data))
- with urlopen(args.url, post_data.encode('utf-8')) as fh:
- logging.info(fh.read().decode('utf-8'))
- logging.info("urlopen done")
-
- except Exception as e:
- logging.error("Errr while trying to insert", e)
-
-while True:
- timed_job()
- sleep(INTERVAL)
-
-=======
- data.append({
- 'measurement': 'usv_parameters',
- 'tags': {
- 'name': name,
- 'id': 'LI????VA',
- },
- 'fields': {'value': parameters[name]}
- });
- print("insert: %s" % ",".join("%s=%s" % \
- (name,parameters[name]) for name in parameters))
-
- 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()
->>>>>>> e3494d280fd6e2db591ea40c4365cdf18524fbdc