n/pacer2influxdb
n
/
pacer2influxdb
1
0
Fork 0
Code Issues Pull Requests Actions Activity

Compare commits

base: n:6e6a7baacaec6a4830eeab0c882ae959ce5efc4e
Branches Tags
n:main
...
compare: n:cdf103af68df7ab5208b451613b12c869b911f31
Branches Tags
n:main

2 Commits
6e6a7baaca ... cdf103af68

Author SHA1 Message Date
n cdf103af68
add short args 2022-02-27 10:26:09 +01:00
n 20cfcf3568
add verbose output 2022-02-27 10:20:35 +01:00
1 changed files with 14 additions and 8 deletions
Show Stats Expand all files Collapse all files

22
pacer2influxdb.py
View File

@ -20,7 +20,8 @@ def main(host='localhost', port=8086, user='root', password='root', dbname='demo
ts=0 ts=0
lastdate=0 lastdate=0
print("last entry is %s, ts is %s" % (lastdate,ts)) if args.verbose:
print("last entry is %s, ts is %s\n" % (lastdate,ts))
con = lite.connect(dbfile) con = lite.connect(dbfile)
with con: with con:
@ -46,7 +47,9 @@ def main(host='localhost', port=8086, user='root', password='root', dbname='demo
} }
] ]
#print(data) if args.verbose:
print("writing data for %s" % (mytime))
db.write_points(data) db.write_points(data)
db.close() db.close()
@ -54,20 +57,23 @@ def parse_args():
"""Parse the args from main.""" """Parse the args from main."""
parser = argparse.ArgumentParser( parser = argparse.ArgumentParser(
description='Export Pacer data to InfluxDB') description='Export Pacer data to InfluxDB')
parser.add_argument('--host', type=str, required=False, parser.add_argument('-v', '--verbose', required=False,
action="store_true",
help='verbose output')
parser.add_argument('-H', '--host', type=str, required=False,
default='localhost', default='localhost',
help='hostname of InfluxDB http API') help='hostname of InfluxDB http API')
parser.add_argument('--user', type=str, required=False, parser.add_argument('-u', '--user', type=str, required=False,
default='root', default='root',
help='username for InfluxDB http API') help='username for InfluxDB http API')
parser.add_argument('--password', type=str, required=False, parser.add_argument('-p', '--password', type=str, required=False,
default='root', default='root',
help='passworid for InfluxDB http API') help='passworid for InfluxDB http API')
parser.add_argument('--port', type=int, required=False, default=8086, parser.add_argument('-P', '--port', type=int, required=False, default=8086,
help='port of InfluxDB http API') help='port of InfluxDB http API')
parser.add_argument('--dbname', type=str, required=True, default='demo', parser.add_argument('-n', '--dbname', type=str, required=True, default='demo',
help='InfluxDB database name') help='InfluxDB database name')
parser.add_argument('--dbfile', type=str, required=True, default='demo.db', parser.add_argument('-f', '--dbfile', type=str, required=True, default='demo.db',
help='sqlite (pacer) database name') help='sqlite (pacer) database name')
return parser.parse_args() return parser.parse_args()