From 505c311389bd7ba203ee16b470259928c9f4ebe0 Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期五, 28 七月 2023 12:34:03 +0800
Subject: [PATCH] bug修复
---
l2/l2_data_manager_new.py | 20 ++++++++++++--------
1 files changed, 12 insertions(+), 8 deletions(-)
diff --git a/l2/l2_data_manager_new.py b/l2/l2_data_manager_new.py
index d02ad46..08d5857 100644
--- a/l2/l2_data_manager_new.py
+++ b/l2/l2_data_manager_new.py
@@ -1,4 +1,4 @@
-import cProfile
+import io
import logging
import time as t
@@ -26,6 +26,9 @@
# TODO l2鏁版嵁绠＄悊
from trade.trade_data_manager import CodeActualPriceProcessor
+
+from line_profiler import LineProfiler
+
import dask
@@ -240,15 +243,16 @@
if place_order_index:
logger_l2_process.info("code:{} 鑾峰彇鍒颁笅鍗曠湡瀹炰綅缃細{}", code, place_order_index)
DCancelBigNumComputer.set_real_order_index(code, place_order_index)
-
__start_time = round(t.time() * 1000)
- pr = cProfile.Profile()
- pr.enable()
- cls.process_add_datas(code, datas, 0, __start_time)
- pr.disable()
- pr.print_stats()
- pr.dump_stats(f"/home/logs/profile/{code}_{round(t.time() * 1000)}.log")
+ lp = LineProfiler()
+ lp_wrap = lp(cls.process_add_datas)
+ lp_wrap(code, datas, 0, __start_time)
+ output = io.StringIO()
+ lp.print_stats(stream=output)
+ with open(f"/home/logs/profile/{code}_{round(t.time() * 1000)}.txt",'w') as f:
+ f.write(output.getvalue())
+ # lp.dump_stats(f"/home/logs/profile/{code}_{round(t.time() * 1000)}.txt")
except Exception as e:
print("huaxin L2鏁版嵁澶勭悊寮傚父", code, str(e))
logging.exception(e)
--
Gitblit v1.8.0