Skip to content

Commit 84288af

Browse files
committed
Will now produce table containing chain temperature readings combined with the
box reading
1 parent 0841047 commit 84288af

File tree

2 files changed

+25
-4
lines changed

2 files changed

+25
-4
lines changed

data_dump.py

Lines changed: 17 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -43,7 +43,8 @@ def get_battery_readings(self):
4343
nodes = self.get_nodes()
4444
self.logger.info("Using nodes %s", nodes)
4545
header = ["timestamp"]
46-
header.extend(nodes)
46+
for node in nodes:
47+
header.append(self.database.get_node_name(node))
4748
data = [header]
4849
data_raw = {}
4950
self.logger.debug(data)
@@ -63,7 +64,8 @@ def get_adc_readings(self, adc):
6364
nodes = self.get_nodes()
6465
self.logger.info("Using nodes %s", nodes)
6566
header = ["timestamp"]
66-
header.extend(nodes)
67+
for node in nodes:
68+
header.append(self.database.get_node_name(node))
6769
data = [header]
6870
data_raw = {}
6971
self.logger.debug(data)
@@ -83,7 +85,8 @@ def get_moisture_readings(self):
8385
nodes = self.get_nodes()
8486
self.logger.info("Using nodes %s", nodes)
8587
header = ["timestamp"]
86-
header.extend(nodes)
88+
for node in nodes:
89+
header.append(self.database.get_node_name(node))
8790
data = [header]
8891
data_raw = {}
8992
self.logger.debug(data)
@@ -103,7 +106,8 @@ def get_rain_readings(self):
103106
nodes = self.get_nodes()
104107
self.logger.info("Using nodes %s", nodes)
105108
header = ["timestamp"]
106-
header.extend(nodes)
109+
for node in nodes:
110+
header.append(self.database.get_node_name(node))
107111
data = [header]
108112
data_raw = {}
109113
self.logger.debug(data)
@@ -167,6 +171,15 @@ def get_chain_readings(self, node):
167171
data.append([i[0], i[1], i[2], i[3], i[4], i[5], i[6], i[7], i[8], i[9], i[10], i[11], i[12]])
168172
return data
169173

174+
def get_chain_temperature_readings(self, node):
175+
raw = self.database.get_chain_temperatures(node)
176+
header = [
177+
"timestamp", "Ambient", "t1", "t2", "t3", "t4"]
178+
data = [header]
179+
for i in raw:
180+
data.append([i[0], i[1], i[2], i[3], i[4], i[5]])
181+
return data
182+
170183
def merge_data(output, node, values):
171184
timestamp = values[0]
172185
value = values[1]

feshiedb.py

Lines changed: 8 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -412,6 +412,14 @@ def get_chain_readings(self, node):
412412
raw = self.db.store_result().fetch_row(0)
413413
return raw
414414

415+
def get_chain_temperatures(self, node):
416+
if self.db is None:
417+
raise FeshieDbError()
418+
self.db.query(
419+
"SELECT timestamp, ambient, t1, t2, t3, t4 FROM chain_temperatures WHERE device_id = \"%s\";"
420+
% node)
421+
return self.db.store_result().fetch_row(0)
422+
415423
def get_moisture_readings(self, node):
416424
if self.db is None:
417425
raise FeshieDbError()

0 commit comments

Comments
 (0)