main.py
@@ -1,5 +1,6 @@ import json import multiprocessing import pickle import threading import time @@ -26,7 +27,7 @@ while True: try: data = queue_l1_w_strategy_r.get() logger_debug.info(f"接收到tick数据：{data}") data = pickle.loads(data) if data.get("type") == 'set_target_codes': # [(代码, 时间戳, 价格, 总交易量, 总交易额, 买5, 卖5)] market_data_list = data["data"]["data"]
