| | |
|---|
| | | 日志 |
|---|
| | | """ |
|---|
| | | import datetime |
|---|
| | | import json |
|---|
| | | import os |
|---|
| | | import sys |
|---|
| | | |
|---|
| | | from loguru import logger |
|---|
| | | |
|---|
| | | import tool |
|---|
| | | |
|---|
| | | |
|---|
| | | class MyLogger: |
|---|
| | |
|---|
| | | logger.add(self.get_path("system", "system"), filter=lambda record: record["extra"].get("name") == "system", |
|---|
| | | rotation="00:00", compression="zip", enqueue=True) |
|---|
| | | |
|---|
| | | logger.add(self.get_path("ths", "buy_1_volumn"), filter=lambda record: record["extra"].get("name") == "buy_1_volumn", |
|---|
| | | logger.add(self.get_path("ths", "buy_1_volumn"), |
|---|
| | | filter=lambda record: record["extra"].get("name") == "buy_1_volumn", |
|---|
| | | rotation="00:00", compression="zip", enqueue=True) |
|---|
| | | |
|---|
| | | logger.add(self.get_path("ths", "buy_1_volumn_record"), |
|---|
| | | filter=lambda record: record["extra"].get("name") == "buy_1_volumn_record", |
|---|
| | | rotation="00:00", compression="zip", enqueue=True) |
|---|
| | | |
|---|
| | | def get_path(self, dir_name, log_name): |
|---|
| | |
|---|
| | | logger_system = __mylogger.get_logger("system") |
|---|
| | | |
|---|
| | | logger_buy_1_volumn = __mylogger.get_logger("buy_1_volumn") |
|---|
| | | |
|---|
| | | logger_buy_1_volumn_record = __mylogger.get_logger("buy_1_volumn_record") |
|---|
| | | |
|---|
| | | |
|---|
| | | class LogUtil: |
|---|
| | |
|---|
| | | __export_l2_trade_log(code, date, dir_) |
|---|
| | | |
|---|
| | | |
|---|
| | | def compute_buy1_real_time(time_): |
|---|
| | | ts = time_.split(":") |
|---|
| | | s = int(ts[0]) * 3600 + int(ts[1]) * 60 + int(ts[2]) |
|---|
| | | cha = (s - 2) % 3 |
|---|
| | | return tool.time_seconds_format(s - 2 - cha) |
|---|
| | | |
|---|
| | | |
|---|
| | | if __name__ == '__main__': |
|---|
| | | # logger_l2_process_time.info("test123") |
|---|
| | | |
|---|
| | | date = datetime.datetime.now().strftime("%Y-%m-%d") |
|---|
| | | LogUtil.extract_log_from_key("002383", "D:/logs/gp/l2/l2_process_time.{}.log".format(date), |
|---|
| | | "D:/logs/gp/l2/l2_process_time{}.{}.log".format("002383", date)) |
|---|
| | | LogUtil.extract_log_from_key("000666", "D:/logs/gp/ths/buy_1_volumn_record.{}.log".format(date), |
|---|
| | | "D:/logs/gp/ths/buy_1_volumn_record{}.{}.log".format("000666", date)) |
|---|
| | | # __analyse_pricess_time() |
|---|
| | | # with open("D:\\logs\\gp\\ths\\buy_1_volumn_record002911.2022-12-01.log",encoding="utf-8") as f: |
|---|
| | | # line = "1" |
|---|
| | | # while line: |
|---|
| | | # line = f.readline() |
|---|
| | | # line = (line.split("-")[-1].replace("'","\"")) |
|---|
| | | # data = json.loads(line) |
|---|
| | | # print(compute_space_time(data["time"]),data["volumn"]) |
|---|
| | | # |
|---|
| | | # print( compute_space_time("10:00:06")) |
|---|
| | | |
|---|
| | | |
|---|
