jacob/OlliTut
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Bug Fix

Browse Source
This commit is contained in:
Jacob Holder 2021-08-11 01:23:23 +02:00
parent 2fbb68d183
commit d19472ce45
Signed by: jacob
GPG Key ID: 2194FC747048A7FD
1 changed files with 9 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
plot_data.py
View File

@ -33,13 +33,12 @@ class PlotData():
self.queues[sensor_name][1].append(dat)
self.extend_timeline()
self.sort_in_queue()
#self.drop_old()
self.drop_old()
def extend_timeline(self):
#extend numpy arrays with passed time
#unknown values are filled with nans
end = (datetime.utcnow()-self.start_time)/timedelta(milliseconds=self.resolution)
print(end, self.start_time)
self.data["time"] = np.arange(0, end, 1).astype(np.double)
for key in self.data:
@ -53,14 +52,18 @@ class PlotData():
time = np.array(self.queues[key][0])
data = np.array(self.queues[key][1])
if time.size > 1:
inter = np.interp(self.data["time"], time, data)
self.data[key] = inter#np.where(np.isnan(inter), self.data[key], inter)
inter = np.interp(self.data["time"], time, data,left=np.nan,right=np.nan)
self.data[key] = np.where(np.isnan(inter), self.data[key], inter)
def drop_old(self):
for key in self.queues:
time = np.array(self.queues[key][0])
old = self.data["time"][-1]-(self.timeout)
if time.size>2:
drop_index = (np.where(time < old)[0])[-1]
self.queues[key] = (self.queues[key][0][drop_index:],self.queues[key][1][drop_index:])
drop_index = (np.where(time < old)[0])
if len(drop_index) is not 0:
drop_index = drop_index[-1]
self.queues[key] = (self.queues[key][0][drop_index:],self.queues[key][1][drop_index:])
print(drop_index)