API订阅回调无法实现延时执行，请求排查5秒等待失效原因

你在回调函数里加time.sleep(5)完全没用，核心原因是：

• 这个on_ticks是API的websocket客户端收到服务商推送的数据时自动触发的，不是你主动调用的。你在这里sleep，只会卡住当前这条数据的处理流程，服务商该推数据还是会按它的频率推，后面的回调会排队等着执行，根本没法控制“每5秒获取一次数据”的节奏。
• 另外，websocket是推送模式，不是你主动拉取——数据是服务商主动发给你的，你没法通过sleep让API“隔5秒发一次”，除非这个API本身提供了设置推送间隔的参数（但大部分实时行情API不会给这个选项）。

要实现“每5秒处理一次最新数据”，得把数据接收和数据处理分开：

1. 回调函数只负责接收数据，把最新的tick数据存到缓存里，别做任何耗时操作
2. 单独开一个线程，专门每隔5秒从缓存里取最新数据，再做你需要的处理（比如添加到abc_list）

修改后的代码示例：

import time
import datetime
import threading

api_ABC_connection = apiConnect(api_key="<apikey>")
api_ABC_connection.ws_connect()

abc_list = []
latest_tick = None  # 用来缓存最新的tick数据

# 回调只做接收，不处理
def on_ticks(ticks):
    global latest_tick
    latest_tick = ticks  # 把最新数据存到全局变量

# 单独的处理线程，每5秒执行一次
def process_data_periodically():
    global latest_tick
    while True:
        if latest_tick is not None:
            print('###################')
            print(datetime.now())
            # 复制一份最新数据，避免被后续推送覆盖
            current_tick = latest_tick.copy()
            # 做你需要的处理
            fetch_time_dict = {'fetch_time': datetime.now()}
            abc_list.append(fetch_time_dict)
            abc_list.append(current_tick)
            print(datetime.now())
        time.sleep(5)

# 配置回调
api_ABC_connection.on_ticks = on_ticks
# 启动处理线程
threading.Thread(target=process_data_periodically, daemon=True).start()

# 订阅行情
api_ABC_connection.subscribe_feeds(<feeds parameters>)

• 如果你的需求是主动拉取数据（而不是接收推送），那你应该放弃websocket方式，改用API的REST接口，然后在循环里每隔5秒调用一次拉取接口。但要注意服务商的接口限流规则，别触发封禁。
• 上面的线程用了daemon=True，这样主程序退出时线程会自动结束，不用手动处理。

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