From 3ce9cb43a4b10efde64ffc700d7c21a3c3c7731d Mon Sep 17 00:00:00 2001
From: admin <admin@example.com>
Date: 星期二, 29 四月 2025 14:39:46 +0800
Subject: [PATCH] 记录日志
---
data_server.py | 14 ++++++++++++++
1 files changed, 14 insertions(+), 0 deletions(-)
diff --git a/data_server.py b/data_server.py
index 220e887..306a99f 100644
--- a/data_server.py
+++ b/data_server.py
@@ -5,6 +5,7 @@
import json
import logging
import socketserver
+import time
from http.server import BaseHTTPRequestHandler
import urllib.parse as urlparse
@@ -122,7 +123,9 @@
response_data = json.dumps({"code": 0, "data": {}})
elif url.path == "/get_env":
+ use_time_list = []
try:
+ __start_time = time.time()
fdata = {}
# try:
# date = HistoryKDatasUtils.get_trading_dates(tool.date_sub(tool.get_now_date_str(), 10),
@@ -145,6 +148,7 @@
fdata["redis"] = 1
except:
fdata["redis"] = 0
+ use_time_list.append(("楠岃瘉redis", time.time() - __start_time))
try:
# 楠岃瘉mysql
@@ -152,12 +156,14 @@
fdata["mysql"] = 1
except:
fdata["mysql"] = 0
+ use_time_list.append(("楠岃瘉mysql", time.time() - __start_time))
try:
# redis寮傛浠诲姟鏁伴噺
fdata["redis_async_task_count"] = redis_manager.RedisUtils.get_async_task_count()
except:
pass
+ use_time_list.append(("楠岃瘉寮傛浠诲姟鏁伴噺", time.time() - __start_time))
# 鑾峰彇浜ゆ槗閫氶亾
try:
@@ -166,17 +172,25 @@
except Exception as e:
logger_debug.exception(e)
fdata["trade_channel_access"] = 0
+ use_time_list.append(("楠岃瘉浜ゆ槗閫氶亾", time.time() - __start_time))
# 鑾峰彇CPU涓庡唴瀛橀�傜敤鎯呭喌
memory_info = psutil.virtual_memory()
cpu_percent = psutil.cpu_percent(interval=1)
fdata["device"] = {"cpu": cpu_percent, "memery": memory_info.percent}
+
+ use_time_list.append(("鑾峰彇璁惧璧勬簮鍗犵敤", time.time() - __start_time))
# 鑾峰彇浜ゆ槗閫氶亾
result = {"code": 0, "data": fdata, "msg": ""}
# print("OnGetEnvInfo 鎴愬姛")
response_data = json.dumps(result)
except Exception as e:
response_data = json.dumps({"code": 1, "msg": str(e)})
+ logger_debug.exception(e)
+ finally:
+ if use_time_list and use_time_list[-1][1] > 10:
+ logger_debug.warning(f"鐜鑾峰彇鏃堕棿澶т簬10s:{use_time_list}")
+
elif url.path == "/load_kpl_stock_of_markets_plate":
# 鍔犺浇鏁版嵁
KPLStockOfMarketsPlateLogManager().load_data()
--
Gitblit v1.8.0