Streamlit集成KiteConnect实时行情报错：signal仅在主解释器主线程生效

核心原因 #

Streamlit依赖主线程渲染UI，而KiteConnect的实时流模块默认会在子线程中尝试注册信号处理逻辑，违反了Python「信号只能在主线程操作」的规则，从而触发ValueError: signal only works in main thread of the main interpreter错误。

具体修复方案 #

1. 禁用KiteConnect的信号自动注册 #

KiteTicker初始化时可通过参数直接关闭信号处理，避免子线程操作信号：

from kiteconnect import KiteTicker

# 初始化实时流时禁用信号
kws = KiteTicker(api_key="你的API_KEY", access_token="你的ACCESS_TOKEN")
kws.connect(disable_signals=True)

如果官方API无此参数，可在主线程提前接管信号：

import signal
# 主线程绑定默认信号处理，阻止子线程修改
signal.signal(signal.SIGINT, signal.default_int_handler)

2. 线程安全的数据流传递 + 主线程更新UI #

禁止在子线程中直接调用Streamlit的UI组件，改用线程安全队列中转数据，主线程循环读取并更新：

import queue
import threading
import streamlit as st
from kiteconnect import KiteTicker

# 线程安全队列存储实时数据
data_queue = queue.Queue()

def on_ticks(ws, ticks):
    # 子线程只负责把数据放入队列
    data_queue.put(ticks)

def on_connect(ws, response):
    ws.subscribe([738561])  # 替换为你的目标股票代码
    ws.set_mode(ws.MODE_FULL, [738561])

# 初始化并启动KiteTicker子线程
kws = KiteTicker(api_key="你的API_KEY", access_token="你的ACCESS_TOKEN")
kws.on_ticks = on_ticks
kws.on_connect = on_connect
t = threading.Thread(target=kws.connect, kwargs={"disable_signals": True}, daemon=True)
t.start()

# 主线程负责UI更新
price_display = st.empty()
while True:
    if not data_queue.empty():
        ticks = data_queue.get()
        latest_price = ticks[0]["last_price"]
        price_display.metric(label="实时股价", value=f"₹{latest_price}")
    st.experimental_rerun()  # 触发UI刷新

3. 升级KiteConnect版本 #

旧版本的KiteConnect可能存在信号处理逻辑的bug，升级到最新版修复潜在问题：

pip install --upgrade kiteconnect

关键注意点 #

• Streamlit的所有UI操作必须在主线程执行，子线程仅负责数据获取与传递。
• Python信号处理严格限制在主线程，任何子线程尝试修改信号都会触发该错误。

内容的提问来源于stack exchange，提问作者Shrinidhi Narasimhan