添加必要的数据日志

admin

3 天以前 0b0d0e790fec8c7edfdbcab5c31d625e0c2eadd6

 log_module/log.py

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

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

        # K线日志
        logger.add(self.get_path("kbars", "k_bars"),
                   filter=lambda record: record["extra"].get("name") == "k_bars",
                   rotation="00:00", compression="zip", enqueue=True)
        # 目标票
        logger.add(self.get_path("codes", "target_codes"),
                   filter=lambda record: record["extra"].get("name") == "target_codes",
                   rotation="00:00", compression="zip", enqueue=True)

        # 看盘日志
        logger.add(self.get_path("kp", "kp_msg"),
                   filter=lambda record: record["extra"].get("name") == "kp_msg",
@@ -303,12 +316,28 @@
                   filter=lambda record: record["extra"].get("name") == "local_huaxin_l2_buy_no",
                   rotation="00:00", compression="zip", enqueue=True)

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

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

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

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

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

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

    def get_path(self, dir_name, log_name):
@@ -408,6 +437,13 @@

logger_kp_msg = __mylogger.get_logger("kp_msg")

logger_kpl_code_plates = __mylogger.get_logger("kpl_code_plates")

logger_k_bars = __mylogger.get_logger("k_bars")

logger_target_codes = __mylogger.get_logger("target_codes")


logger_redis_debug = __mylogger.get_logger("redis_debug")

logger_profile = __mylogger.get_logger("profile")
@@ -434,7 +470,12 @@
logger_local_huaxin_trade_debug = __mylogger.get_logger("local_huaxin_trade_debug")
logger_local_huaxin_l1 = __mylogger.get_logger("local_huaxin_l1_show_info")

# -------------------------------开盘啦日志---------------------------------
logger_kpl_jingxuan_in = __mylogger.get_logger("kpl_jingxuan_in")
logger_kpl_market_sift_plate = __mylogger.get_logger("kpl_market_sift_plate")
logger_Overall_market_strength_score = __mylogger.get_logger("Overall_market_strength_score")
logger_stock_of_markets_plate = __mylogger.get_logger("stock_of_markets_plate")
logger_stock_of_markets_plate_simple = __mylogger.get_logger("stock_of_markets_plate_simple")

logger_common = __mylogger.get_logger("common")