记录日志

admin

2025-04-29 3ce9cb43a4b10efde64ffc700d7c21a3c3c7731d

记录日志

 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()