From 8218790ab15e752d982ee9c0df156ceea849c9a9 Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期一, 05 十二月 2022 22:02:47 +0800
Subject: [PATCH] 策略优化，增加买1价格的影响
---
log.py | 34 +++++++++++++++++++++++++++++++---
1 files changed, 31 insertions(+), 3 deletions(-)
diff --git a/log.py b/log.py
index 808cd0f..d341ad3 100644
--- a/log.py
+++ b/log.py
@@ -2,10 +2,13 @@
鏃ュ織
"""
import datetime
+import json
import os
import sys
from loguru import logger
+
+import tool
class MyLogger:
@@ -64,7 +67,12 @@
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):
@@ -94,6 +102,8 @@
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:
@@ -152,10 +162,28 @@
__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"))
+
+
--
Gitblit v1.8.0