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

Compare commits

base: n:44d7bd91594007259169290478cc69be27f21474
Branches Tags
n:main
..
compare: n:54c29480171d60e50c8a4e09380e6a44c8390b9b
Branches Tags
n:main

3 commits
44d7bd9159 ... 54c2948017

Author SHA1 Message Date
n
54c2948017
update README
All checks were successful
lint / lint (push) Successful in 32s
Details
2024-02-13 23:20:43 +01:00
n
4ffb56328f
add Gitea CI
All checks were successful
lint / lint (push) Successful in 33s
Details
2024-02-13 22:39:43 +01:00
n
64bfd5b9d3
pylint fixes 2024-02-13 22:39:43 +01:00
1 changed files with 11 additions and 11 deletions
Show stats Expand all files Collapse all files

22
pacer2influxdb.py
View file

@ -11,31 +11,31 @@ from influxdb import InfluxDBClient
def main(args): def main(args):
"""Instantiate the connection to the InfluxDB client.""" """Instantiate the connection to the InfluxDB client."""
influx_db = InfluxDBClient(args.host, args.port, args.user, args.password, args.dbname) influx_db = InfluxDBClient(args.host, args.port, args.user, args.password, args.dbname)
measurements = influx_db.get_list_measurements() measurementime_stamp = influx_db.get_list_measurementime_stamp()
time_stamp = 0 time_stamp = 0
lastdate = 0 lastdate = 0
laststeps = 0 lastime_stampteps = 0
if measurements != []: if measurementime_stamp != []:
lastentry = influx_db.query('SELECT LAST("steps") FROM "steps"') lastentry = influx_db.query('SELECT LAST("steps") FROM "steps"')
points = lastentry.get_points('steps') pointime_stamp = lastentry.get_pointime_stamp('steps')
lastdate = list(points)[0]['time'] lastdate = list(pointime_stamp)[0]['time']
time_stamp = time.mktime(datetime.datetime.strptime(lastdate, '%Y-%m-%dT%H:%M:%SZ') time_stamp = time.mktime(datetime.datetime.strptime(lastdate, '%Y-%m-%dT%H:%M:%SZ')
.timetuple()) .timetuple())
if time_stamp == datetime.datetime.now().timestamp() // 86400 * 86400 + time.timezone: if time_stamp == datetime.datetime.now().timestamp() // 86400 * 86400 + time.timezone:
points = lastentry.get_points('steps') pointime_stamp = lastentry.get_pointime_stamp('steps')
laststeps = list(points)[0]['last'] lastime_stampteps = list(pointime_stamp)[0]['last']
if args.verbose: if args.verbose:
print(f'last entry is {lastdate}, timestamp is {time_stamp}, \ print(f'last entry is {lastdate}, time_stamp is {time_stamp}, \
number of steps is {laststeps}\n') number of steps is {lastime_stampteps}\n')
con = lite.connect(args.dbfile) con = lite.connect(args.dbfile)
with con: with con:
cur = con.cursor() cur = con.cursor()
cur.execute(f'SELECT recordedForDate,steps,distanceInMeters,activeTimeInSeconds,calories \ cur.execute(f'SELECT recordedForDate,steps,distanceInMeters,activeTimeInSeconds,calories \
FROM dailyActivityLog \ FROM dailyActivityLog \
WHERE recordedForDate >= {time_stamp} AND steps > {laststeps}') WHERE recordedForDate >= {time_stamp} AND steps > {lastime_stampteps}')
while True: while True:
row = cur.fetchone() row = cur.fetchone()
if row is None: if row is None:
@ -52,7 +52,7 @@ def main(args):
}] }]
if args.verbose: if args.verbose:
print(f'writing data for {mytime}') print(f'writing data for {mytime}')
influx_db.write_points(data) influx_db.write_pointime_stamp(data)
influx_db.close() influx_db.close()
def parse_args(): def parse_args():