acereca/bath
acereca
/
bath
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

update 20180612 1600

This commit is contained in:
acereca 2018-06-12 15:42:41 +02:00
parent e25fe4ed31
commit 6fd8ff68cd
3 changed files with 1259 additions and 27 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1264
data/aggregate.csv
View File

File diff suppressed because it is too large Load Diff

BIN
data/aggregate.pdf Normal file
View File

Binary file not shown.

22
data/aggregator.py
View File

@ -2,13 +2,17 @@ import json
import socket import socket
import pandas as pd import pandas as pd
import numpy as np import numpy as np
import sys
sys.path.append("./raspi-i2c")
import i2c2 as i2c
import matplotlib.pyplot as plt
timefrm = "%Y-%m-%d+%H:%M:%S" timefrm = "%Y-%m-%d+%H:%M:%S"
def get_new_entry(): def get_new_entry(setting={}):
s = socket.socket(socket.AF_INET, socket.SOCK_STREAM) s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
s.connect(('localhost', 8888)) s.connect(('localhost', 8888))
s.sendall(b'{"set":{"type":"addr","addr":0,"val":15}}') s.sendall(json.dumps(setting).encode())
response =json.loads(''.join(e.decode("utf-8") for e in s.recv(1024).split()[5:])) response =json.loads(''.join(e.decode("utf-8") for e in s.recv(1024).split()[5:]))
s.close() s.close()
@ -17,16 +21,24 @@ def get_new_entry():
if __name__ == '__main__': if __name__ == '__main__':
pit = i2c.PIT()
try: try:
data = pd.read_csv("aggregate.csv") data = pd.read_csv("aggregate.csv")
except: except:
data = pd.DataFrame(pd.Series(get_new_entry())).T data = pd.DataFrame(pd.Series(get_new_entry())).T
print(data) print(data)
for i in range(10):
data = data.append(pd.Series(get_new_entry()), ignore_index=True) for i in range(100):
data = data.append(
pd.Series(get_new_entry()),
ignore_index=True)
print(i) print(i)
# whitespace would be removed when transmitted # whitespace would be removed when transmitted
data.systime = pd.to_datetime(data.systime, format=timefrm) data.systime = pd.to_datetime(data.systime, format=timefrm)
data.to_csv("aggregate.csv", date_format=timefrm) data.to_csv("aggregate.csv", date_format=timefrm, index=False)
data.plot('systime', 'pit_mon48v')
plt.savefig("aggregate.pdf")