From 7e8854fb75eb35b0c243c7e61b5a580ea8775ff8 Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期三, 23 八月 2023 16:13:35 +0800
Subject: [PATCH] 记录L2数据传输耗时日志
---
huaxin_client/l2_data_manager.py | 8 ++++++--
1 files changed, 6 insertions(+), 2 deletions(-)
diff --git a/huaxin_client/l2_data_manager.py b/huaxin_client/l2_data_manager.py
index a881b80..d47971e 100644
--- a/huaxin_client/l2_data_manager.py
+++ b/huaxin_client/l2_data_manager.py
@@ -10,7 +10,7 @@
from huaxin_client.client_network import SendResponseSkManager
# 娲诲姩鏃堕棿
-from log_module.log import logger_local_huaxin_l2_error
+from log_module.log import logger_local_huaxin_l2_error, logger_local_huaxin_l2_upload
order_detail_upload_active_time_dict = {}
transaction_upload_active_time_dict = {}
@@ -60,7 +60,7 @@
tmep_order_detail_queue_dict[code].put(
(data['SecurityID'], data['Price'], data['Volume'], data['Side'], data['OrderType'], data['OrderTime'],
- data['MainSeq'], data['SubSeq'], data['OrderNO'], data['OrderStatus'], int(time.time()*1000)))
+ data['MainSeq'], data['SubSeq'], data['OrderNO'], data['OrderStatus'], int(time.time() * 1000)))
# 娣诲姞閫愮瑪鎴愪氦
@@ -166,7 +166,11 @@
temp = tmep_order_detail_queue_dict[code].get()
udatas.append(temp)
if udatas:
+ start_time = time.time()
upload_data(code, "l2_order", udatas)
+ use_time = int((time.time() - start_time)*1000)
+ if use_time > 20:
+ logger_local_huaxin_l2_upload.info(f"{code}-涓婁紶浠ｇ爜鑰楁椂锛歿use_time}ms")
time.sleep(0.01)
--
Gitblit v1.8.0