From 4b116fdec0f32b32c14ca25a589facb944f98e83 Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期四, 28 三月 2024 15:53:40 +0800
Subject: [PATCH] bug修复
---
huaxin_client/l2_data_manager.py | 7 ++++---
1 files changed, 4 insertions(+), 3 deletions(-)
diff --git a/huaxin_client/l2_data_manager.py b/huaxin_client/l2_data_manager.py
index 7388f44..c76fcb3 100644
--- a/huaxin_client/l2_data_manager.py
+++ b/huaxin_client/l2_data_manager.py
@@ -179,12 +179,13 @@
# self.__upload_l2_data(code, upload_queue, temp_list)
# self.__upload_l2_order_data(code, temp_list)
__start_time = time.time()
+ last_data = temp_list[-1]
self.data_callback_distribute_manager.get_distributed_callback(code).OnL2Order(code, temp_list,
time.time())
use_time = time.time() - __start_time
if use_time > 0.01:
# 璁板綍10ms浠ヤ笂鐨勬暟鎹�
- huaxin_l2_log.info(logger_local_huaxin_l2_error, f"鑰楁椂:{use_time}s 缁撴潫鏁版嵁锛歿temp_list[-1]}")
+ huaxin_l2_log.info(logger_local_huaxin_l2_error, f"鑰楁椂:{use_time}s 缁撴潫鏁版嵁锛歿last_data}")
temp_list = []
else:
if code not in self.temp_order_queue_dict:
@@ -196,7 +197,7 @@
except Exception as e:
logging.exception(e)
finally:
- pass
+ temp_list.clear()
# 澶勭悊鎴愪氦鏁版嵁骞朵笂浼�
def __run_upload_transaction_task(self, code):
@@ -224,7 +225,7 @@
except:
pass
finally:
- pass
+ temp_list.clear()
def __run_log_task(self, code):
q: queue.Queue = self.temp_log_queue_dict.get(code)
--
Gitblit v1.8.0