fix: make demo boll run

Author: BugenZhao

demo.py

@@ -1,6 +1,8 @@
 import logging
 import threading
 
+import pandas as pd
+
 
 def run(*fs):
     for f in fs:
@@ -43,8 +45,8 @@ def on_tick_changes(data: list):
     # Callback when receiving changes from tick_analytics
     # Print the new average price if the avg price for a symbol in the last 10s is greater than 300
     def on_tick_analytics_changes(data: pd.DataFrame):
-        COLOR = '\033[92m'
-        ENDC = '\033[0m'
+        COLOR = "\033[92m"
+        ENDC = "\033[0m"
         for _, row in data.iterrows():
             # Print the new average price if the avg price for a symbol in the last 10s is greater than 300
             if (row["op"] == "UpdateInsert" or row["op"] == "Insert") and row[
@@ -132,15 +134,21 @@ def demo_boll():
 
     def handle_binance_klines_update(data):
         k = data["data"]["k"]
+        df = pd.DataFrame(
+            {
+                "symbol": k["s"],
+                "timestamp": datetime.fromtimestamp(k["t"] / 1000),
+                "open": float(k["o"]),
+                "high": float(k["h"]),
+                "low": float(k["l"]),
+                "close": float(k["c"]),
+                "volume": float(k["v"]),
+            },
+            index=[0],
+        )
         rw.insert(
             table_name="usdm_futures_klins_1m",
-            symbol=k["s"],
-            timestamp=datetime.fromtimestamp(k["t"] / 1000),
-            open=float(k["o"]),
-            high=float(k["h"]),
-            low=float(k["l"]),
-            close=float(k["c"]),
-            volume=float(k["v"]),
+            data=df,
         )
 
     def subscribe_binance():