51 lines
1.6 KiB
Python
51 lines
1.6 KiB
Python
|
|
class AccumulatorSensor(Readable):
|
|
def __init__(self, averager, index):
|
|
self.averager =averager
|
|
self.index =index
|
|
|
|
def read(self):
|
|
return self.averager.values[self.index]
|
|
|
|
class Accumulator(ReadonlyRegisterBase, ReadonlyRegisterArray):
|
|
def __init__(self, devices, integration_time=None):
|
|
ReadonlyRegisterBase.__init__(self, "Averager")
|
|
self.devices = devices
|
|
self.integration_time = integration_time
|
|
self.initialize()
|
|
self.samples = [[],] * len(devices)
|
|
self.values = []
|
|
|
|
def getSize(self):
|
|
return len(self.devices)
|
|
|
|
def doRead(self):
|
|
start = time.time()
|
|
self.samples = []
|
|
for i in range(self.getSize()):
|
|
self.samples.append([])
|
|
values = []
|
|
while True:
|
|
for i in range (self.getSize()):
|
|
v = self.devices[i].read()
|
|
self.samples[i].append(v)
|
|
if self.integration_time is None or (time.time() - start) >= self.integration_time:
|
|
break
|
|
sleep(0.1)
|
|
self.values = []
|
|
for i in range (self.getSize()):
|
|
self.values.append(mean(self.samples[i]))
|
|
return self.values
|
|
|
|
def getSensor(self, index):
|
|
return AveragerSensor(self, index)
|
|
|
|
def getSensors(self):
|
|
ret = []
|
|
for i in range (self.getSize()):
|
|
ret.append(AveragerSensor(self,i))
|
|
return ret
|
|
|
|
acc = Accumulator([signal_tey, signal_i0, signal_trans], integration_time = 0.5)
|
|
tscan ([acc,] + acc.sensors, 10, 3.0)
|
|
|