异常保护

Administrator

4 天以前 48fb7a00951f91bdc707e5dd2d196e5bccb752c3

 log_module/log.py

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

        logger.add(self.get_path("code_attribute", "pre_close_price"),
                   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)
@@ -70,6 +78,14 @@

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

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

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

        logger.add(self.get_path("l2", "l2_trade_buy"),
@@ -104,6 +120,18 @@
                   filter=lambda record: record["extra"].get("name") == "l2_market_sell",
                   rotation="00:00", compression="zip", enqueue=True)

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

        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"),
                   filter=lambda record: record["extra"].get("name") == "juejin_tick",
                   rotation="00:00", compression="zip", enqueue=True)
@@ -118,6 +146,10 @@

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

        logger.add(self.get_path("strategy", "buy_strategy"),
                   filter=lambda record: record["extra"].get("name") == "buy_strategy",
                   rotation="00:00", compression="zip", enqueue=True)
        # 显示在控制台
        # logger.add(sys.stdout,
@@ -157,8 +189,16 @@
                   filter=lambda record: record["extra"].get("name") == "debug",
                   rotation="00:00", compression="zip", enqueue=True)

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

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

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

        logger.add(self.get_path("score", "place_order_score"),
@@ -173,12 +213,46 @@
                   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)

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

        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)

        # 看盘日志
@@ -198,15 +272,47 @@
        logger.add(self.get_hx_path("l2", "transaction"),
                   filter=lambda record: record["extra"].get("name") == "hx_l2_transaction",
                   rotation="00:00", compression="zip", enqueue=True)

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

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

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

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

        logger.add(self.get_hx_path("l2", "orderdetail"),
                   filter=lambda record: record["extra"].get("name") == "hx_l2_orderdetail",
                   rotation="00:00", compression="zip", enqueue=True)
        logger.add(self.get_hx_path("l2", "marketdata"),
                   filter=lambda record: record["extra"].get("name") == "hx_l2_market_data",
                   rotation="00:00", compression="zip", enqueue=True)
        logger.add(self.get_hx_path("l2", "marketdata"),
                   filter=lambda record: record["extra"].get("name") == "hx_l2_market_data_before_open",
                   rotation="00:00", compression="zip", enqueue=True)
        logger.add(self.get_hx_path("l2", "upload"),
                   filter=lambda record: record["extra"].get("name") == "hx_l2_upload",
                   rotation="00:00", compression="zip", enqueue=True)
        logger.add(self.get_hx_path("l2", "debug"),
                   filter=lambda record: record["extra"].get("name") == "hx_l2_debug",
                   rotation="00:00", compression="zip", enqueue=True)

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

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

        logger.add(self.get_hx_path("contact", "debug"),
                   filter=lambda record: record["extra"].get("name") == "hx_contact_debug",
                   rotation="00:00", compression="zip", enqueue=True)
@@ -219,10 +325,21 @@
        logger.add(self.get_hx_path("trade", "trade_loop"),
                   filter=lambda record: record["extra"].get("name") == "hx_trade_loop",
                   rotation="00:00", compression="zip", enqueue=True)
        logger.add(self.get_hx_path("trade", "l2_active_sell"),
                   filter=lambda record: record["extra"].get("name") == "hx_l2_active_sell",
                   rotation="00:00", compression="zip", enqueue=True)

        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)
@@ -250,8 +367,16 @@
                   filter=lambda record: record["extra"].get("name") == "local_huaxin_l1_show_info",
                   rotation="00:00", compression="zip", enqueue=True)

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

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

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

        logger.add(self.get_local_huaxin_path("l2", "l2_buy_no"),
@@ -290,15 +415,17 @@
logger_l2_data = __mylogger.get_logger("l2_data")
logger_l2_latest_data = __mylogger.get_logger("l2_latest_data")
logger_l2_market_sell = __mylogger.get_logger("l2_market_sell")

logger_l2_not_buy_reasons = __mylogger.get_logger("l2_not_buy_reasons")

logger_l2_trade = __mylogger.get_logger("l2_trade")
logger_l2_trade_cancel = __mylogger.get_logger("l2_trade_cancel")
logger_l2_s_cancel = __mylogger.get_logger("s_cancel")
logger_l2_h_cancel = __mylogger.get_logger("h_cancel")
logger_l2_d_cancel = __mylogger.get_logger("d_cancel")
logger_l2_f_cancel = __mylogger.get_logger("f_cancel")
logger_l2_l_cancel = __mylogger.get_logger("l_cancel")
logger_l2_g_cancel = __mylogger.get_logger("g_cancel")
logger_l2_j_cancel = __mylogger.get_logger("j_cancel")
logger_l2_trade_buy = __mylogger.get_logger("l2_trade_buy")
logger_l2_trade_queue = __mylogger.get_logger("l2_trade_queue")
logger_l2_trade_buy_queue = __mylogger.get_logger("l2_trade_buy_queue")
@@ -306,7 +433,6 @@
logger_real_place_order_position = __mylogger.get_logger("l2_real_place_order_position")
# 代码订阅日志
logger_l2_codes_subscript = __mylogger.get_logger("l2_codes_subscript")


logger_l2_big_data = __mylogger.get_logger("l2_big_data")
logger_juejin_tick = __mylogger.get_logger("juejin_tick")
@@ -330,7 +456,11 @@

logger_debug = __mylogger.get_logger("debug")

logger_request_api = __mylogger.get_logger("request_api")

logger_trade_record = __mylogger.get_logger("trade_record")

logger_trade_position_api_request = __mylogger.get_logger("position_api_request")

logger_place_order_score = __mylogger.get_logger("place_order_score")

@@ -338,9 +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")

@@ -350,18 +505,35 @@

logger_mysql_debug = __mylogger.get_logger("mysql_debug")

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")
hx_logger_l2_transaction = __mylogger.get_logger("hx_l2_transaction")
hx_logger_l2_transaction_sell_order = __mylogger.get_logger("hx_l2_transaction_sell_order")
hx_logger_l2_transaction_desc = __mylogger.get_logger("hx_l2_transaction_desc")
hx_logger_l2_transaction_big_buy_order = __mylogger.get_logger("hx_l2_transaction_big_buy")
hx_logger_l2_transaction_big_sell_order = __mylogger.get_logger("hx_l2_transaction_big_sell")
hx_logger_l2_market_data = __mylogger.get_logger("hx_l2_market_data")
hx_logger_l2_market_data_before_open = __mylogger.get_logger("hx_l2_market_data_before_open")
hx_logger_l2_upload = __mylogger.get_logger("hx_l2_upload")
hx_logger_l2_debug = __mylogger.get_logger("hx_l2_debug")
hx_logger_contact_debug = __mylogger.get_logger("hx_contact_debug")
hx_logger_trade_callback = __mylogger.get_logger("hx_trade_callback")
hx_logger_trade_debug = __mylogger.get_logger("hx_trade_debug")
hx_logger_trade_loop = __mylogger.get_logger("hx_trade_loop")
hx_logger_l2_active_sell = __mylogger.get_logger("hx_l2_active_sell")
hx_logger_l2_sell_delegate = __mylogger.get_logger("hx_l2_sell_delegate")
hx_logger_l2_sell_deal = __mylogger.get_logger("hx_l2_sell_deal")

# -------------------------------华鑫本地日志---------------------------------
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")
@@ -371,6 +543,13 @@
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_pre_close_price = __mylogger.get_logger("pre_close_price")
logger_codes_zyltgb = __mylogger.get_logger("codes_zyltgb")



def close_print():
@@ -381,6 +560,5 @@


if __name__ == "__main__":
    close_print()
    logger_local_huaxin_l1.info("测试")
    input()
    open_limit_up_codes = set({"000333", "000222"})
    logger_kpl_open_limit_up.info(f"炸板代码：{open_limit_up_codes}")