Delete ch-11/pc-live-graph directory
This commit is contained in:
@@ -1,59 +0,0 @@
|
||||
""" Turn JSON data stream into graphs"""
|
||||
import requests
|
||||
import json
|
||||
|
||||
import matplotlib.pyplot as plt
|
||||
from matplotlib.animation import FuncAnimation
|
||||
|
||||
url = "http://192.168.1.128"
|
||||
|
||||
|
||||
class AnimatedGraph:
|
||||
def __init__(self):
|
||||
self.fields = {}
|
||||
self.samples = 100
|
||||
self.reset()
|
||||
print("getting source to iterate over")
|
||||
self.source = self._graph_source()
|
||||
print("init completed")
|
||||
|
||||
def reset(self):
|
||||
for field in self.fields:
|
||||
self.fields[field] = []
|
||||
|
||||
def _graph_source(self):
|
||||
while True:
|
||||
try:
|
||||
with requests.get(url, timeout=1, stream=True) as response:
|
||||
print(f"status: {response.status_code}")
|
||||
yield from response.iter_lines()
|
||||
except requests.exceptions.RequestException:
|
||||
pass
|
||||
|
||||
def make_frame(self, frame):
|
||||
print("loading next item")
|
||||
item = json.loads(next(self.source))
|
||||
print("item loaded")
|
||||
if 'time' in self.fields and item["time"] < self.fields['time'][-1]:
|
||||
self.reset()
|
||||
for field in item:
|
||||
if field not in self.fields:
|
||||
self.fields[field] = []
|
||||
self.fields[field].append(item[field])
|
||||
|
||||
if len(self.fields['time'] ) > self.samples:
|
||||
for field in self.fields:
|
||||
self.fields[field] = self.fields[field][-self.samples:]
|
||||
|
||||
plt.cla() # clear axes.
|
||||
# plot the items
|
||||
for field in self.fields:
|
||||
if field != "time":
|
||||
plt.plot("time", field, data=self.fields)
|
||||
|
||||
plt.legend(loc="upper right")
|
||||
|
||||
# Create the animation. gcf - get current figure. random_stream - callback func.
|
||||
animation = FuncAnimation(plt.gcf(), AnimatedGraph().make_frame, interval=200)
|
||||
plt.tight_layout()
|
||||
plt.show()
|
||||
@@ -1,2 +0,0 @@
|
||||
matplotlib
|
||||
requests
|
||||
Reference in New Issue
Block a user