diff --git a/pacer2influxdb.py b/pacer2influxdb.py index 541e1f4..f4e9056 100755 --- a/pacer2influxdb.py +++ b/pacer2influxdb.py @@ -10,24 +10,27 @@ def main(host='localhost', port=8086, user='root', password='root', dbname='demo db = InfluxDBClient(host, port, user, password, dbname) measurements = db.get_list_measurements() + ts = 0 + lastdate = 0 + laststeps = 0 if measurements != []: lastentry = db.query('SELECT LAST("steps") FROM "steps"') points = lastentry.get_points('steps') lastdate = list(points)[0]['time'] ts = time.mktime(datetime.datetime.strptime(lastdate, '%Y-%m-%dT%H:%M:%SZ').timetuple()) - else: - ts=0 - lastdate=0 + if ts == datetime.datetime.now().timestamp() // 86400 * 86400 + time.timezone: + points = lastentry.get_points('steps') + laststeps = list(points)[0]['last'] if args.verbose: - print("last entry is %s, ts is %s\n" % (lastdate,ts)) + print("last entry is %s, ts is %s, number of steps is %s\n" % (lastdate,ts,laststeps)) con = lite.connect(dbfile) with con: cur = con.cursor() - cur.execute("SELECT recordedForDate,steps,distanceInMeters,activeTimeInSeconds,calories FROM dailyActivityLog WHERE recordedForDate > %s" %ts) + cur.execute("SELECT recordedForDate,steps,distanceInMeters,activeTimeInSeconds,calories FROM dailyActivityLog WHERE recordedForDate >= %s AND steps > %s" % (ts,laststeps)) while True: