Spaces:
Runtime error
Runtime error
File size: 3,082 Bytes
82a7fd2 c8c2db2 82a7fd2 c8c2db2 82a7fd2 c8c2db2 6b95d04 641e286 c8c2db2 82a7fd2 4f49508 82a7fd2 6b95d04 c8c2db2 82a7fd2 c8c2db2 82a7fd2 c8c2db2 82a7fd2 641e286 82a7fd2 c8c2db2 641e286 c8c2db2 |
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 |
import streamlit as st
import pandas as pd
import numpy as np
import requests
import time
from datetime import datetime
import altair as alt
st.set_page_config(
page_title="Real-Time IoT",
page_icon="✅",
layout="wide",
)
st.title("Iot Data")
DATA_URL = 'https://trace.vfsc.vn/iot/xxx'
# def stream():
# s = requests.Session()
# with requests.get(DATA_URL, headers=None, stream=True, params={"items":160}) as response:
# # print(response.status_code)
# for line in response.iter_lines():
# if line: print(line)
# # print(line.decode('utf-8')['data'])
# stream()
def load_data(n):
response = requests.get(DATA_URL) if n <= 0 else requests.get(DATA_URL, params = {"items": n})
plan = response.json()['plan']
data = response.json()['data']
return data
def is_duplicate(s):
# st.write(s)
if st.session_state["duplicates"]:
check_candidate = (s["Id"], s["Time"])
res = check_candidate in st.session_state["duplicates"]
st.session_state["duplicates"].add(check_candidate)
else:
st.session_state["duplicates"] = set()
return res
# if "count" not in st.session_state:
# st.session_state['count'] = 10
df = pd.DataFrame.from_dict(load_data(10))
df.rename({'Lat' : 'lat', 'Lng' : 'lon'}, axis='columns', inplace=True)
st.session_state["duplicates"] = set(zip(df["Id"], df["Time"]))
col1, col2 = st.columns(2)
graph_type = "Bar"
data_col = "STemp"
with col1:
data_col = st.selectbox(
"Choose column to plot",
[col for col in df.columns if col.lower() in "upt, batv, solv, stemp".split(", ")],
)
# st.checkbox("Disable selectbox widget", key="disabled")
graph_type = st.radio(
"Choose graph type 👉",
('Bar', 'Line'),
)
with col2:
placeholder = st.empty()
while True:
# new_df = pd.DataFrame.from_dict(load_data(st.session_state["count"]))
# new_df.rename({'Lat' : 'lat', 'Lng' : 'lon'}, axis='columns', inplace=True)
new_data = pd.DataFrame.from_dict(load_data(0)).rename({'Lat' : 'lat', 'Lng' : 'lon'}, axis='columns').iloc[-1]
# print(df.iloc[-1]["Id"], new_data["Id"])
if is_duplicate(new_data):
pass
# st.write("Dup")
else:
df.loc[len(df)] = new_data
# df = pd.concat([df, pd.DataFrame(new_ele)])
chart_data = pd.DataFrame(
df[data_col].tolist(),
df["moment"].apply(lambda timestr : datetime.strptime(timestr, '%d/%m/%Y %H:%M:%S').time().strftime("%H:%M:%S")).tolist()
)
# chart_data.set_index('date')
with placeholder.container():
if graph_type == 'Line':
st.line_chart(chart_data)
elif graph_type == 'Bar':
st.bar_chart(chart_data)
# st.bar_chart(chart_data["data"], y = chart_data["label"])
# st.map(df)
st.write(df)
time.sleep(2)
# st.write(st.session_state)
# st.session_state["count"] += 1 |