Compare commits
3 Commits
54c2948017
...
44d7bd9159
Author | SHA1 | Date |
---|---|---|
n | 44d7bd9159 | |
n | 9f19b7d326 | |
n | aa16c1f792 |
|
@ -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)
|
||||||
measurementime_stamp = influx_db.get_list_measurementime_stamp()
|
measurements = influx_db.get_list_measurements()
|
||||||
time_stamp = 0
|
time_stamp = 0
|
||||||
lastdate = 0
|
lastdate = 0
|
||||||
lastime_stampteps = 0
|
laststeps = 0
|
||||||
if measurementime_stamp != []:
|
if measurements != []:
|
||||||
lastentry = influx_db.query('SELECT LAST("steps") FROM "steps"')
|
lastentry = influx_db.query('SELECT LAST("steps") FROM "steps"')
|
||||||
pointime_stamp = lastentry.get_pointime_stamp('steps')
|
points = lastentry.get_points('steps')
|
||||||
lastdate = list(pointime_stamp)[0]['time']
|
lastdate = list(points)[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:
|
||||||
pointime_stamp = lastentry.get_pointime_stamp('steps')
|
points = lastentry.get_points('steps')
|
||||||
lastime_stampteps = list(pointime_stamp)[0]['last']
|
laststeps = list(points)[0]['last']
|
||||||
|
|
||||||
if args.verbose:
|
if args.verbose:
|
||||||
print(f'last entry is {lastdate}, time_stamp is {time_stamp}, \
|
print(f'last entry is {lastdate}, timestamp is {time_stamp}, \
|
||||||
number of steps is {lastime_stampteps}\n')
|
number of steps is {laststeps}\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 > {lastime_stampteps}')
|
WHERE recordedForDate >= {time_stamp} AND steps > {laststeps}')
|
||||||
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_pointime_stamp(data)
|
influx_db.write_points(data)
|
||||||
influx_db.close()
|
influx_db.close()
|
||||||
|
|
||||||
def parse_args():
|
def parse_args():
|
||||||
|
|
Loading…
Reference in New Issue