unfix

app.py

@@ -4,7 +4,8 @@ import numpy as np
 import requests
 import time
 from datetime import datetime
-import altair as alt
+from timeit import default_timer as timer
+from datetime import timedelta
 
 st.set_page_config(
     page_title="Real-Time IoT",
@@ -38,16 +39,16 @@ def load_data(n):
 
 def is_duplicate(s):
     # st.write(s)
-    if st.session_state["duplicates"]:
+    res = False
+    if "duplicates" in st.session_state:
         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()
+    st.session_state["duplicates"].add(check_candidate)
     return res
 
-# if "count" not in st.session_state:
-#     st.session_state['count'] = 10
+if 'time' not in st.session_state:
+    st.session_state['time'] = timer()
+
 
 df = pd.DataFrame.from_dict(load_data(10))
 df.rename({'Lat' : 'lat', 'Lng' : 'lon'}, axis='columns', inplace=True)
@@ -77,13 +78,19 @@ with col2:
         # 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
+        curr_time = timer()
+
+        # st.write(timedelta(seconds = curr_time - st.session_state['time']))
+        if curr_time - st.session_state['time'] >= 2:
+            st.write("Passed")
+            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
+            st.session_state['time'] = curr_time
 
         # df = pd.concat([df, pd.DataFrame(new_ele)])
 
@@ -99,9 +106,8 @@ with col2:
                 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)
+        # time.sleep(15)
         # st.write(st.session_state)
         # st.session_state["count"] += 1