diff --git a/pacer2influxdb.py b/pacer2influxdb.py
index 541e1f4..46e6189 100755
--- a/pacer2influxdb.py
+++ b/pacer2influxdb.py
@@ -15,19 +15,23 @@ def main(host='localhost', port=8086, user='root', password='root', dbname='demo
 
         points = lastentry.get_points('steps')
         lastdate = list(points)[0]['time']
+        points = lastentry.get_points('steps')
+        laststeps = list(points)[0]['last']
+
         ts = time.mktime(datetime.datetime.strptime(lastdate, '%Y-%m-%dT%H:%M:%SZ').timetuple())
     else:
         ts=0
         lastdate=0
+        laststeps=0
 
     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: