Split Xively streams and debug upload

[~andy/csm213a-hw] / vis / test.py

diff --git a/vis/test.py b/vis/test.py
index abb4d6f3878c04203218cabf31c9b8f6f281d630..c7ce9cad0d9f7670e8631e6ca3e0208d934aa7c0 100644 (file)
--- a/vis/test.py
+++ b/vis/test.py
@@ -71,11 +71,17 @@ class TestXively:
        api_key = 'Py7atAQt2vAI5AFeWsUJMDqpIE1Dra5b0rPzlnr2ZDvDDoI5'
 
        # Times
-       time0   = datetime.datetime(2014,2,3, 3,0,0)
-       time1   = datetime.datetime(2014,2,3, 3,1,0)
-       time2   = datetime.datetime(2014,2,3, 3,2,0)
-       time3   = datetime.datetime(2014,2,3, 3,3,0)
-       time4   = datetime.datetime(2014,2,3, 3,4,0)
+       now     = datetime.datetime.utcnow();
+       time0   = now-datetime.timedelta(0,0*60); # datetime.datetime(2014,2,3, 3,0,0)
+       time1   = now-datetime.timedelta(0,1*60); # datetime.datetime(2014,2,3, 3,1,0)
+       time2   = now-datetime.timedelta(0,2*60); # datetime.datetime(2014,2,3, 3,2,0)
+       time3   = now-datetime.timedelta(0,3*60); # datetime.datetime(2014,2,3, 3,3,0)
+       time4   = now-datetime.timedelta(0,4*60); # datetime.datetime(2014,2,3, 3,4,0)
+       time5   = now-datetime.timedelta(0,5*60); # datetime.datetime(2014,2,3, 3,4,0)
+       time6   = now-datetime.timedelta(0,6*60); # datetime.datetime(2014,2,3, 3,4,0)
+       time7   = now-datetime.timedelta(0,7*60); # datetime.datetime(2014,2,3, 3,4,0)
+       time8   = now-datetime.timedelta(0,8*60); # datetime.datetime(2014,2,3, 3,4,0)
+       time9   = now-datetime.timedelta(0,9*60); # datetime.datetime(2014,2,3, 3,4,0)
 
        # Constructor
        def __init__(self):
@@ -84,22 +90,32 @@ class TestXively:
 
        # Update the feed
        def send(self):
-               acc = Datastream(id='acc')
+               acc = Datastream(id='test_acc')
                acc.datapoints = [
-                       Datapoint(self.time0, [1, 1, 1]),
-                       Datapoint(self.time1, [2, 2, 2]),
-                       Datapoint(self.time2, [3, 3, 3]),
-                       Datapoint(self.time3, [4, 4, 4]),
-                       Datapoint(self.time4, [5, 5, 5]),
+                       Datapoint(self.time0, [00, 1, 1]),
+                       Datapoint(self.time1, [10, 2, 2]),
+                       Datapoint(self.time2, [20, 3, 3]),
+                       Datapoint(self.time3, [30, 4, 4]),
+                       Datapoint(self.time4, [40, 5, 5]),
+                       Datapoint(self.time5, [50, 5, 5]),
+                       Datapoint(self.time6, [60, 5, 5]),
+                       Datapoint(self.time7, [70, 5, 5]),
+                       Datapoint(self.time8, [80, 5, 5]),
+                       Datapoint(self.time9, [90, 5, 5]),
                ]
 
-               mag = Datastream(id='mag')
+               mag = Datastream(id='test_mag')
                mag.datapoints = [
-                       Datapoint(self.time0, [1, 1, 1]),
-                       Datapoint(self.time1, [2, 2, 2]),
-                       Datapoint(self.time2, [3, 3, 3]),
-                       Datapoint(self.time3, [4, 4, 4]),
-                       Datapoint(self.time4, [5, 5, 5]),
+                       Datapoint(self.time0, 00),
+                       Datapoint(self.time1, 10),
+                       Datapoint(self.time2, 20),
+                       Datapoint(self.time3, 30),
+                       Datapoint(self.time4, 40),
+                       Datapoint(self.time5, 50),
+                       Datapoint(self.time6, 60),
+                       Datapoint(self.time7, 70),
+                       Datapoint(self.time8, 80),
+                       Datapoint(self.time9, 90),
                ]
 
                self.feed.datastreams = [ acc, mag ]
@@ -107,7 +123,7 @@ class TestXively:
 
        # Read it back
        def recv(self):
-               stream = self.feed.datastreams.get('acc')
+               stream = self.feed.datastreams.get('test_acc')
                points = stream.datapoints.history( \
                        start=self.time0, end=self.time4, interval=0)