From 0d5aa806d1b8aae5a44e6897cea1df51988d0123 Mon Sep 17 00:00:00 2001 From: Administrator <admin@example.com> Date: 星期四, 17 八月 2023 14:59:25 +0800 Subject: [PATCH] 删除redis日志与时间日志 --- huaxin_api/l1_client.py | 7 +++++-- log_module/log.py | 7 +++++++ 2 files changed, 12 insertions(+), 2 deletions(-) diff --git a/huaxin_api/l1_client.py b/huaxin_api/l1_client.py index 4f1f7fd..e960f1f 100644 --- a/huaxin_api/l1_client.py +++ b/huaxin_api/l1_client.py @@ -9,7 +9,7 @@ import xmdapi from huaxin_api import tool from huaxin_api.client_network import SendResponseSkManager -from log_module.log import logger_system +from log_module.log import logger_system, logger_local_huaxin_l1 level1_data_dict = { @@ -162,12 +162,15 @@ def run(pipe_l2): time.sleep(10) + logger_local_huaxin_l1.info("杩愯l1璁㈤槄鏈嶅姟") codes_sh = [] codes_sz = [] for i in range(3): try: codes_sh, codes_sz = get_level1_codes() - except: + logger_local_huaxin_l1.info(f"鑾峰彇涓婅瘉锛屾繁璇佷唬鐮佹暟閲忥細sh-{len(codes_sh)} sz-{len(codes_sz)}") + except Exception as e: + logger_local_huaxin_l1.exception(e) time.sleep(4) # 鎵撳嵃鎺ュ彛鐗堟湰鍙� diff --git a/log_module/log.py b/log_module/log.py index 7fde0a4..44ac785 100644 --- a/log_module/log.py +++ b/log_module/log.py @@ -223,6 +223,9 @@ logger.add(self.get_local_huaxin_path("trade", "trade_debug"), filter=lambda record: record["extra"].get("name") == "local_huaxin_trade_debug", rotation="00:00", compression="zip", enqueue=True) + logger.add(sys.stdout, + filter=lambda record: record["extra"].get("name") == "local_huaxin_l1_show_info", enqueue=True) + def get_path(self, dir_name, log_name): path_str = "{}/logs/gp/{}/{}".format(constant.get_path_prefix(), dir_name, log_name) + ".{time:YYYY-MM-DD}.log" @@ -326,6 +329,10 @@ logger_local_huaxin_l2_subscript = __mylogger.get_logger("local_huaxin_subscript") logger_local_huaxin_contact_debug = __mylogger.get_logger("local_huaxin_debug") logger_local_huaxin_trade_debug = __mylogger.get_logger("local_huaxin_trade_debug") +logger_local_huaxin_l1 = __mylogger.get_logger("local_huaxin_l1_show_info") + + + def close_print(): -- Gitblit v1.8.0