From a29622874377f194aa83b5c51422d7ce5516bd9c Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期四, 14 九月 2023 13:41:57 +0800
Subject: [PATCH] 线程ID记录
---
huaxin_client/l2_data_manager.py | 7 ++++++-
1 files changed, 6 insertions(+), 1 deletions(-)
diff --git a/huaxin_client/l2_data_manager.py b/huaxin_client/l2_data_manager.py
index 9b59bf4..d700f08 100644
--- a/huaxin_client/l2_data_manager.py
+++ b/huaxin_client/l2_data_manager.py
@@ -15,7 +15,8 @@
from huaxin_client.l2_data_transform_protocol import L2DataCallBack
from log_module import log_export, async_log_util
from log_module.log import logger_local_huaxin_l2_error, logger_local_huaxin_l2_upload, logger_local_huaxin_l2_buy_no, \
- logger_local_huaxin_g_cancel, hx_logger_contact_debug
+ logger_local_huaxin_g_cancel, hx_logger_contact_debug, logger_system
+from utils import tool
order_detail_upload_active_time_dict = {}
transaction_upload_active_time_dict = {}
@@ -229,6 +230,7 @@
def __run_upload_common(l2_data_callback: L2DataCallBack):
print("__run_upload_common")
+ logger_system.info(f"l2_client __run_upload_common 绾跨▼ID:{tool.get_thread_id()}")
while True:
try:
while not common_queue.empty():
@@ -247,6 +249,7 @@
def __run_upload_trading_canceled(l2_data_callback: L2DataCallBack):
print("__run_upload_trading_canceled")
+ logger_system.info(f"l2_client __run_upload_trading_canceled 绾跨▼ID:{tool.get_thread_id()}")
while True:
try:
temp = trading_canceled_queue.get()
@@ -262,6 +265,7 @@
def __run_log():
print("__run_log")
+ logger_system.info(f"l2_client __run_log 绾跨▼ID:{tool.get_thread_id()}")
while True:
try:
temp = log_buy_no_queue.get()
@@ -316,6 +320,7 @@
# 杩愯瀹堟姢绾跨▼
def run_upload_daemon(_l2_data_callback):
def upload_daemon():
+ logger_system.info(f"l2_client upload_daemon 绾跨▼ID:{tool.get_thread_id()}")
while True:
try:
for code in target_codes_add_time:
--
Gitblit v1.8.0