From 4ee1bd5de9ca76a69adac6e17a11bd686c742ef3 Mon Sep 17 00:00:00 2001
From: admin <weikou2014>
Date: 星期三, 22 五月 2024 18:57:54 +0800
Subject: [PATCH] 融入交易
---
data_server.py | 12 +++++-------
1 files changed, 5 insertions(+), 7 deletions(-)
diff --git a/data_server.py b/data_server.py
index 1308eec..e16b735 100644
--- a/data_server.py
+++ b/data_server.py
@@ -6,10 +6,8 @@
import dask
-import log
from code_attribute import gpcode_manager
-from log import logger_request_debug
-from log_module import log_analyse, log_export
+from log_module import log_analyse, log_export, log, request_log_util
from output import limit_up_data_filter, output_util
from output.limit_up_data_filter import IgnoreCodeManager
from third_data import kpl_util, kpl_data_manager, kpl_api
@@ -273,7 +271,7 @@
def do_GET(self):
path = self.path
url = urlparse.urlparse(path)
- log.request_info("DATA_SERVER_GET", f"GET 璇锋眰寮�濮嬶細{url.path}")
+ request_log_util.request_info("DATA_SERVER_GET", f"GET 璇锋眰寮�濮嬶細{url.path}")
try:
if url.path == "/kpl/get_limit_up_list":
response_data = self.__get_limit_up_list()
@@ -287,12 +285,12 @@
result = hosting_api_util.get_from_data_server(url.path, ps_dict)
self.__send_response(result)
finally:
- log.request_info("DATA_SERVER_GET", f"GET 璇锋眰缁撴潫")
+ request_log_util.request_info("DATA_SERVER_GET", f"GET 璇锋眰缁撴潫")
def do_POST(self):
path = self.path
url = urlparse.urlparse(path)
- log.request_info("DATA_SERVER_POST", f"POST 璇锋眰寮�濮嬶細{url.path}")
+ request_log_util.request_info("DATA_SERVER_POST", f"POST 璇锋眰寮�濮嬶細{url.path}")
try:
if url.path == "/upload_kpl_data":
# 鎺ュ彈寮�鐩樺暒鏁版嵁
@@ -300,7 +298,7 @@
result_str = self.__process_kpl_data(params)
self.__send_response(result_str)
finally:
- log.request_info("DATA_SERVER_POST", f"POST 璇锋眰缁撴潫")
+ request_log_util.request_info("DATA_SERVER_POST", f"POST 璇锋眰缁撴潫")
def __process_kpl_data(self, data):
data = json.loads(json.dumps(data).replace("姒傚康", ""))
--
Gitblit v1.8.0