为大单净流入添加日志文件

Administrator

2024-11-19 340927061f8be6e308927e76039e9917197a2479

为大单净流入添加日志文件

 l2_test.py

@@ -7,7 +7,7 @@
import requests

from huaxin_client import l2_client_test, l1_subscript_codes_manager
from log_module.log import logger_local_huaxin_l2_upload
from log_module.log import logger_local_huaxin_l2_transaction_big_order
from third_data.custom_block_in_money_manager import CodeInMoneyManager, BlockInMoneyRankManager


@@ -33,7 +33,7 @@
        try:
            data = big_order_queue.get()
            CodeInMoneyManager().add_data(data)
            logger_local_huaxin_l2_upload.info(f"{data}")
            logger_local_huaxin_l2_transaction_big_order.info(f"{data}")
        except:
            pass


 log_module/log.py

@@ -306,6 +306,10 @@
        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)
        logger.add(self.get_local_huaxin_path("l2", "transaction_big_order"),
                   filter=lambda record: record["extra"].get("name") == "local_huaxin_transaction_for_big_order",
                   rotation="00:00", compression="zip", enqueue=True)

        logger.add(self.get_local_huaxin_path("l2", "orderdetail"),
                   filter=lambda record: record["extra"].get("name") == "local_huaxin_orderdetail",
                   rotation="00:00", compression="zip", enqueue=True)
@@ -481,6 +485,7 @@

# -------------------------------华鑫本地日志---------------------------------
logger_local_huaxin_l2_transaction = __mylogger.get_logger("local_huaxin_transaction")
logger_local_huaxin_l2_transaction_big_order = __mylogger.get_logger("local_huaxin_transaction_for_big_order")
logger_local_huaxin_l2_orderdetail = __mylogger.get_logger("local_huaxin_orderdetail")
logger_local_huaxin_l2_upload = __mylogger.get_logger("local_huaxin_upload")
logger_local_huaxin_l2_error = __mylogger.get_logger("local_huaxin_error")

 third_data/custom_block_in_money_manager.py

@@ -2,6 +2,7 @@
自定义板块流入金额
"""
import copy
import os

import constant
from huaxin_client import l1_subscript_codes_manager
@@ -17,12 +18,14 @@
        self.__load_data()

    def __load_data(self):
        with open(f"{constant.get_path_prefix()}\\logs\\huaxin_local\\l2\\upload.{tool.get_now_date_str()}.log") as f:
            lines = f.readlines()
            for line in lines:
                line = line.split(" - ")[1]
                item = eval(line)
                self.add_data(item)
        _path = f"{constant.get_path_prefix()}/logs/huaxin_local/l2/transaction_big_order.{tool.get_now_date_str()}.log"
        if os.path.exists(_path):
            with open(_path) as f:
                lines = f.readlines()
                for line in lines:
                    line = line.split(" - ")[1]
                    item = eval(line)
                    self.add_data(item)

    def add_data(self, item):
        code = item[0]