1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
|
#!/usr/bin/env python3
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
INTERVAL=24 # execution takes about 6s
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:])
logging.basicConfig(level=logging.DEBUG,
filename='log/usv_scheduler.log',
format='%(asctime)s %(message)s',
datefmt='%Y-%m-%d %H:%M:%S')
usv = Usv(args.serial, int(args.baud), args.param)
def timed_job():
parameters = usv.get_parameters()
data = []
for name in parameters:
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)
|
