From 39e36db75d8cece9c5235ba65fde78dc9a4e591a Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期三, 18 六月 2025 11:30:21 +0800
Subject: [PATCH] ‘功能完善
---
huaxin_client/l2_market_client.py | 5 +++--
main.py | 3 ++-
2 files changed, 5 insertions(+), 3 deletions(-)
diff --git a/huaxin_client/l2_market_client.py b/huaxin_client/l2_market_client.py
index db683e6..43430e4 100644
--- a/huaxin_client/l2_market_client.py
+++ b/huaxin_client/l2_market_client.py
@@ -4,6 +4,7 @@
import logging
import multiprocessing
import os
+import pickle
import queue
import time
import concurrent.futures
@@ -207,8 +208,8 @@
# 涓婁紶鏁版嵁
type_ = "set_target_codes"
request_id = f"sb_{int(time.time() * 1000)}"
- fdata = json.dumps(
- {"type": type_, "data": {"data": datas}, "request_id": request_id, "time": round(time.time() * 1000, 0)})
+ fdata = pickle.dumps(
+ {"type": type_, "data": {"data": datas}, "request_id": request_id, "time": round(time.time() * 1000, 0)}, protocol=pickle.HIGHEST_PROTOCOL)
if queue_l1_w_strategy_r is not None:
queue_l1_w_strategy_r.put_nowait(fdata)
# 璁板綍鏂板鍔犵殑浠ｇ爜
diff --git a/main.py b/main.py
index dbbf0bb..059d0fb 100644
--- a/main.py
+++ b/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"鎺ユ敹鍒皌ick鏁版嵁锛歿data}")
+ data = pickle.loads(data)
if data.get("type") == 'set_target_codes':
# [(浠ｇ爜, 鏃堕棿鎴�, 浠锋牸, 鎬讳氦鏄撻噺, 鎬讳氦鏄撻, 涔�5, 鍗�5)]
market_data_list = data["data"]["data"]
--
Gitblit v1.8.0