| | |
| | | logger.add(get_path("l2", "l2_trade"), filter=lambda record: record["extra"].get("name") == "l2_trade", |
| | | 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.add(get_path("juejin", "juejin_tick"), filter=lambda record: record["extra"].get("name") == "juejin_tick", |
| | | rotation="00:00", compression="zip", enqueue=True) |
| | | |
| | |
| | | logger_l2_error = logger.bind(name="l2_error") |
| | | logger_l2_process = logger.bind(name="l2_process") |
| | | logger_l2_trade = logger.bind(name="l2_trade") |
| | | logger_l2_big_data = logger.bind(name="l2_big_data") |
| | | logger_juejin_tick = logger.bind(name="juejin_tick") |
| | | logger_code_operate = logger.bind(name="code_operate") |
| | | logger_device = logger.bind(name="device") |