添加必要的数据日志

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,6 +316,30 @@
                   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("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):
        path_str = "{}/{}/gp/{}/{}".format(constant.get_path_prefix(), constant.LOG_DIR, dir_name,
                                           log_name) + ".{time:YYYY-MM-DD}.log"
@@ -400,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")
@@ -420,19 +464,22 @@
hx_logger_trade_loop = __mylogger.get_logger("hx_trade_loop")

# -------------------------------华鑫本地日志---------------------------------
logger_local_huaxin_l2_transaction = __mylogger.get_logger("local_huaxin_transaction")
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")
logger_local_huaxin_l2_subscript = __mylogger.get_logger("local_huaxin_subscript")
logger_local_huaxin_l2_market = __mylogger.get_logger("local_huaxin_l2_market")
logger_local_huaxin_contact_debug = __mylogger.get_logger("local_huaxin_debug")
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_local_huaxin_g_cancel = __mylogger.get_logger("local_huaxin_g_cancel")
logger_local_huaxin_l2_buy_no = __mylogger.get_logger("local_huaxin_l2_buy_no")
logger_local_huaxin_l1_trade_info = __mylogger.get_logger("local_huaxin_l1_trade_info")
logger_local_huaxin_l2_special_volume = __mylogger.get_logger("local_huaxin_l2_special_volume")

# -------------------------------开盘啦日志---------------------------------
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")




def close_print():