From faa10757d0cdc1da06ba48d01d47fd69868cf96f Mon Sep 17 00:00:00 2001
From: admin <admin@example.com>
Date: 星期一, 17 三月 2025 18:20:27 +0800
Subject: [PATCH] 日志调整
---
data_server.py | 62 ++++++++++++++++++++++++++++++
1 files changed, 61 insertions(+), 1 deletions(-)
diff --git a/data_server.py b/data_server.py
index 4ef16d3..260e89b 100644
--- a/data_server.py
+++ b/data_server.py
@@ -7,11 +7,15 @@
from http.server import BaseHTTPRequestHandler
import urllib.parse as urlparse
+import psutil
+
+from db import redis_manager_delegate as redis_manager, mysql_data_delegate as mysql_data
+from db.redis_manager_delegate import RedisUtils
from log_module.log import hx_logger_l2_transaction, logger_debug
from strategy import data_cache
from trade import huaxin_trade_api, huaxin_trade_data_update
from trade.huaxin_trade_record_manager import DelegateRecordManager, DealRecordManager, MoneyManager, PositionManager
-from utils import tool, huaxin_util
+from utils import tool, huaxin_util, socket_util
class DataServer(BaseHTTPRequestHandler):
@@ -95,6 +99,62 @@
# 鑾峰彇姣忔涔板叆鐨勯噾棰�
money = data_cache.BUY_MONEY_PER_CODE
response_data = json.dumps({"code": 0, "data": {"money": money}})
+ elif url.path == "/get_env":
+ try:
+ fdata = {}
+ # try:
+ # date = HistoryKDatasUtils.get_trading_dates(tool.date_sub(tool.get_now_date_str(), 10),
+ # tool.get_now_date_str())
+ # if date:
+ # fdata["juejin"] = 1
+ # except Exception as e:
+ # fdata["juejin"] = 0
+ # fdata["kpl"] = {}
+ # # 鑾峰彇寮�鐩樺暒鏁版嵁
+ # kpl_types = [KPLDataType.LIMIT_UP.value, KPLDataType.JINGXUAN_RANK.value,
+ # KPLDataType.INDUSTRY_RANK.value]
+ # for kpl_type in kpl_types:
+ # if kpl_type in KPLDataManager.kpl_data_update_info:
+ # fdata["kpl"][kpl_type] = KPLDataManager.kpl_data_update_info.get(kpl_type)
+
+ try:
+ # 楠岃瘉redis
+ RedisUtils.get(redis_manager.RedisManager(0).getRedis(), "test")
+ fdata["redis"] = 1
+ except:
+ fdata["redis"] = 0
+
+ try:
+ # 楠岃瘉mysql
+ mysql_data.Mysqldb().select_one("select 1")
+ fdata["mysql"] = 1
+ except:
+ fdata["mysql"] = 0
+
+ try:
+ # redis寮傛浠诲姟鏁伴噺
+ fdata["redis_async_task_count"] = redis_manager.RedisUtils.get_async_task_count()
+ except:
+ pass
+
+ # 鑾峰彇浜ゆ槗閫氶亾
+ try:
+ can_access = huaxin_trade_api.test_trade_channel()
+ fdata["trade_channel_access"] = 1 if can_access else 0
+ except Exception as e:
+ logger_debug.exception(e)
+ fdata["trade_channel_access"] = 0
+
+ # 鑾峰彇CPU涓庡唴瀛橀�傜敤鎯呭喌
+ memory_info = psutil.virtual_memory()
+ cpu_percent = psutil.cpu_percent(interval=1)
+ fdata["device"] = {"cpu": cpu_percent, "memery": memory_info.percent}
+ # 鑾峰彇浜ゆ槗閫氶亾
+ 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)})
self.send_response(200)
# 鍙戠粰璇锋眰瀹㈡埛绔殑鍝嶅簲鏁版嵁
--
Gitblit v1.8.0