| | |
| | | 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) |
| | |
| | | |
| | | 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"), |
| | |
| | | |
| | | 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_pre_close_price = __mylogger.get_logger("pre_close_price") |
| | | logger_codes_zyltgb = __mylogger.get_logger("codes_zyltgb") |
| | | |
| | | |
| | | |
| | | def close_print(): |