日志修改

Administrator

2024-03-22 6142a09ed31bcb0f0049a826a12227234b9c2b8c

日志修改

 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"

 trade/trade_strategy.py

@@ -218,6 +218,7 @@
                async_log_util.info(logger_trade_position_api_request, f"{code}请求持仓耗时：{use_time * 1000}ms")

    def OnRefreshTradeData(self, client_id, request_id, data):
        logger_debug.info(f"交易数据刷新：{data}")
        try:
            sync_type = data["ctype"]
            if sync_type == "position_list":