gp_binance_demo/kappa/main.py

# import asyncio
from ws_client import start_ws_clients
import warnings

# 忽略 FutureWarning
warnings.simplefilter(action='ignore', category=FutureWarning)

# 启动 WebSocket 客户端
start_ws_clients()

# 停止所有线程（在需要停止时调用）
# stop_all_threads()