异常保护

Administrator

4 天以前 48fb7a00951f91bdc707e5dd2d196e5bccb752c3

 log_module/log.py

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

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

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

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

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

        logger.add(self.get_path("juejin", "juejin_tick"),
@@ -205,6 +213,12 @@
                   filter=lambda record: record["extra"].get("name") == "kpl_limit_up",
                   rotation="00:00", compression="zip", enqueue=True)

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



        logger.add(self.get_path("kpl", "kpl_debug"),
                   filter=lambda record: record["extra"].get("name") == "kpl_debug",
                   rotation="00:00", compression="zip", enqueue=True)
@@ -215,6 +229,30 @@

        logger.add(self.get_path("kpl", "kpl_open_limit_up"),
                   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_jx_out"),
                   filter=lambda record: record["extra"].get("name") == "kpl_jx_out",
                   rotation="00:00", compression="zip", enqueue=True)

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

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

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

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

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

        # 看盘日志
@@ -294,6 +332,14 @@
        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", "transaction_accurate_big_order"),
                   filter=lambda record: record["extra"].get("name") == "local_huaxin_transaction_for_accurate_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)
@@ -422,11 +468,34 @@

logger_kpl_limit_up = __mylogger.get_logger("kpl_limit_up")

logger_kpl_new_blocks = __mylogger.get_logger("kpl_new_blocks")

logger_kpl_debug = __mylogger.get_logger("kpl_debug")

logger_kpl_block_can_buy = __mylogger.get_logger("kpl_block_can_buy")

logger_kpl_open_limit_up = __mylogger.get_logger("kpl_open_limit_up")

logger_kpl_jx_out = __mylogger.get_logger("kpl_jx_out")

logger_kpl_jx_in = __mylogger.get_logger("kpl_jx_in")

logger_kpl_latest_gaobiao = __mylogger.get_logger("kpl_latest_gaobiao")

# 开盘啦市场强度
logger_kpl_market_strong = __mylogger.get_logger("kpl_market_strong")



logger_plate_special_codes = __mylogger.get_logger("plate_special_codes")

logger_plate_code_plates = __mylogger.get_logger("plate_code_plates")







logger_kp_msg = __mylogger.get_logger("kp_msg")

@@ -439,6 +508,8 @@
logger_buy_strategy = __mylogger.get_logger("buy_strategy")

logger_l2_radical_buy = __mylogger.get_logger("l2_radical_buy")

logger_l2_radical_buy_data = __mylogger.get_logger("l2_radical_buy_data")

# -------------------------------华鑫日志---------------------------------
hx_logger_l2_orderdetail = __mylogger.get_logger("hx_l2_orderdetail")
@@ -461,6 +532,8 @@

# -------------------------------华鑫本地日志---------------------------------
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_transaction_accurate_big_order = __mylogger.get_logger("local_huaxin_transaction_for_accurate_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")
@@ -475,6 +548,8 @@

# 收盘价日志
logger_pre_close_price = __mylogger.get_logger("pre_close_price")
logger_codes_zyltgb = __mylogger.get_logger("codes_zyltgb")



def close_print():