mysql日志

Administrator

2023-10-25 84c1492e824bc26cf8ee962e8cf93d94e86b7c9e

mysql日志

 db/mysql_data_delegate.py

@@ -5,6 +5,7 @@

# 把连接参数定义成字典
import constant
from log_module.log import logger_mysql_debug
from utils import middle_api_protocol

config = constant.MYSQL_CONFIG
@@ -23,8 +24,11 @@
        if args:
            data["args"] = args
        fdata = middle_api_protocol.load_mysql_cmd(data)
        result = middle_api_protocol.request(fdata)
        return result
        try:
            result = middle_api_protocol.request(fdata)
            return result
        except Exception as e:
            logger_mysql_debug.exception(e)

    # 查询sql语句返回的所有数据
    def select_all(self, sql):

 log_module/log.py

@@ -40,6 +40,10 @@
                   filter=lambda record: record["extra"].get("name") == "l2_latest_data",
                   rotation="00:00", compression="zip", enqueue=True)

        logger.add(self.get_path("mysql", "mysql_debug"),
                   filter=lambda record: record["extra"].get("name") == "mysql_debug",
                   rotation="00:00", compression="zip", enqueue=True)

        # 显示在控制台
        # logger.add(sys.stdout,
        #           filter=lambda record: record["extra"].get("name") == "l2_trade", enqueue=True)
@@ -338,6 +342,8 @@

logger_profile = __mylogger.get_logger("profile")

logger_mysql_debug = __mylogger.get_logger("mysql_debug")

# -------------------------------华鑫日志---------------------------------
hx_logger_l2_orderdetail = __mylogger.get_logger("hx_l2_orderdetail")
hx_logger_l2_transaction = __mylogger.get_logger("hx_l2_transaction")