From 81af04babd4938a865aeb1ab0a338ad4593f5980 Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期四, 14 九月 2023 13:50:38 +0800
Subject: [PATCH] 线程ID记录
---
huaxin_client/l2_client.py | 8 +++-----
1 files changed, 3 insertions(+), 5 deletions(-)
diff --git a/huaxin_client/l2_client.py b/huaxin_client/l2_client.py
index 32662df..bd6d876 100644
--- a/huaxin_client/l2_client.py
+++ b/huaxin_client/l2_client.py
@@ -150,13 +150,11 @@
def set_code_special_watch_volume(self, code, volume):
# 鏈夋晥鏈熶负2s
self.special_code_volume_for_order_dict[code] = (volume, time.time() + 2)
- async_log_util.info(logger_local_huaxin_l2_subscript,f"璁剧疆涓嬪崟閲忕洃鍚細{code}-{volume}")
-
-
+ async_log_util.info(logger_local_huaxin_l2_subscript, f"璁剧疆涓嬪崟閲忕洃鍚細{code}-{volume}")
def OnFrontConnected(self):
print("OnFrontConnected")
-
+ logger_system.info(f"l2_client OnFrontConnected 绾跨▼ID:{tool.get_thread_id()}")
logout_req = lev2mdapi.CTORATstpUserLogoutField()
self.__api.ReqUserLogout(logout_req, 1)
time.sleep(1)
@@ -579,7 +577,7 @@
pipe_strategy = None
-def run(pipe_trade, _pipe_strategy, _l2_data_callback: l2_data_transform_protocol.L2DataCallBack)->None:
+def run(pipe_trade, _pipe_strategy, _l2_data_callback: l2_data_transform_protocol.L2DataCallBack) -> None:
logger_system.info("L2杩涚▼ID锛歿}", os.getpid())
logger_system.info(f"l2_client 绾跨▼ID:{tool.get_thread_id()}")
try:
--
Gitblit v1.8.0