From 6142a09ed31bcb0f0049a826a12227234b9c2b8c Mon Sep 17 00:00:00 2001 From: Administrator <admin@example.com> Date: 星期五, 22 三月 2024 16:53:40 +0800 Subject: [PATCH] 日志修改 --- log_module/log.py | 42 ++++++++++++++++++++++++++++++++++++++++++ 1 files changed, 42 insertions(+), 0 deletions(-) diff --git a/log_module/log.py b/log_module/log.py index f996290..c27a616 100644 --- a/log_module/log.py +++ b/log_module/log.py @@ -214,6 +214,44 @@ filter=lambda record: record["extra"].get("name") == "profile", rotation="00:00", compression="zip", enqueue=True) + ################################鍗庨懌鏃ュ織################################ + logger.add(self.get_hx_path("l2", "transaction"), + filter=lambda record: record["extra"].get("name") == "hx_l2_transaction", + rotation="00:00", compression="zip", enqueue=True) + + logger.add(self.get_hx_path("l2", "transaction_sell_order"), + filter=lambda record: record["extra"].get("name") == "hx_l2_transaction_sell_order", + rotation="00:00", compression="zip", enqueue=True) + + logger.add(self.get_hx_path("l2", "transaction_desc"), + filter=lambda record: record["extra"].get("name") == "hx_l2_transaction_desc", + rotation="00:00", compression="zip", enqueue=True) + logger.add(self.get_hx_path("l2", "orderdetail"), + filter=lambda record: record["extra"].get("name") == "hx_l2_orderdetail", + rotation="00:00", compression="zip", enqueue=True) + logger.add(self.get_hx_path("l2", "marketdata"), + filter=lambda record: record["extra"].get("name") == "hx_l2_market_data", + rotation="00:00", compression="zip", enqueue=True) + logger.add(self.get_hx_path("l2", "upload"), + filter=lambda record: record["extra"].get("name") == "hx_l2_upload", + rotation="00:00", compression="zip", enqueue=True) + logger.add(self.get_hx_path("l2", "debug"), + filter=lambda record: record["extra"].get("name") == "hx_l2_debug", + rotation="00:00", compression="zip", enqueue=True) + + logger.add(self.get_hx_path("contact", "debug"), + filter=lambda record: record["extra"].get("name") == "hx_contact_debug", + rotation="00:00", compression="zip", enqueue=True) + logger.add(self.get_hx_path("trade", "trade_callback"), + filter=lambda record: record["extra"].get("name") == "hx_trade_callback", + rotation="00:00", compression="zip", enqueue=True) + logger.add(self.get_hx_path("trade", "debug"), + filter=lambda record: record["extra"].get("name") == "hx_trade_debug", + rotation="00:00", compression="zip", enqueue=True) + logger.add(self.get_hx_path("trade", "trade_loop"), + filter=lambda record: record["extra"].get("name") == "hx_trade_loop", + rotation="00:00", compression="zip", enqueue=True) + logger.add(self.get_local_huaxin_path("l2", "transaction"), filter=lambda record: record["extra"].get("name") == "local_huaxin_transaction", rotation="00:00", compression="zip", enqueue=True) @@ -265,6 +303,10 @@ log_name) + ".{time:YYYY-MM-DD}.log" return path_str + def get_hx_path(self, dir_name, log_name): + path_str = "{}/sell_logs/huaxin/{}/{}".format(constant.get_path_prefix(), dir_name, + log_name) + ".{time:YYYY-MM-DD}.log" + def get_local_huaxin_path(self, dir_name, log_name): path_str = "{}/sell_logs/huaxin_local/{}/{}".format(constant.get_path_prefix(), dir_name, log_name) + ".{time:YYYY-MM-DD}.log" -- Gitblit v1.8.0