| | |
| | | |
| | | logger.add(get_path("l2", "l2_trade_cancel"), filter=lambda record: record["extra"].get("name") == "l2_trade_cancel", |
| | | rotation="00:00", compression="zip", enqueue=True) |
| | | logger.add(get_path("l2", "l2_trade_buy"), filter=lambda record: record["extra"].get("name") == "l2_trade_buy", |
| | | rotation="00:00", compression="zip", enqueue=True) |
| | | |
| | | logger.add(get_path("l2", "l2_big_data"), filter=lambda record: record["extra"].get("name") == "l2_big_data", |
| | | rotation="00:00", compression="zip", enqueue=True) |
| | |
| | | logger_l2_process = logger.bind(name="l2_process") |
| | | logger_l2_trade = logger.bind(name="l2_trade") |
| | | logger_l2_trade_cancel = logger.bind(name="l2_trade_cancel") |
| | | logger_l2_trade_buy = logger.bind(name="l2_trade_buy") |
| | | |
| | | |
| | | logger_l2_big_data = logger.bind(name="l2_big_data") |