Administrator
2023-10-25 84c1492e824bc26cf8ee962e8cf93d94e86b7c9e
mysql日志
2个文件已修改
10 ■■■■■ 已修改文件
db/mysql_data_delegate.py 4 ●●●● 补丁 | 查看 | 原始文档 | blame | 历史
log_module/log.py 6 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
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)
        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")