From be73e2b78857adaf006063275726b69c4c60f0d7 Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期三, 12 十月 2022 11:54:25 +0800
Subject: [PATCH] 买撤策略修改；加入报警功能
---
trade_manager.py | 17 +++++++++++++----
1 files changed, 13 insertions(+), 4 deletions(-)
diff --git a/trade_manager.py b/trade_manager.py
index a6a94cf..e82fae4 100644
--- a/trade_manager.py
+++ b/trade_manager.py
@@ -307,8 +307,8 @@
keys = redis_l2.keys("*{}*".format(code))
for k in keys:
- if (k.find("l2-") is None or k.find("l2-") < 0) and (k.find("big_data-") is None or k.find("big_data-") < 0):
- redis_l2.delete(k)
+ # if (k.find("l2-") is None or k.find("l2-") < 0) and (k.find("big_data-") is None or k.find("big_data-") < 0):
+ redis_l2.delete(k)
redis_trade = redis_manager.RedisManager(2).getRedis()
redis_trade.delete("trade-state-{}".format(code))
@@ -316,11 +316,20 @@
redis_info = redis_manager.RedisManager(0).getRedis()
keys = redis_info.keys("*{}*".format(code))
for k in keys:
- if k.find("pre") is None or k.find("pre") < 0:
+ if k.find("pre") is None or k.find("pre") or k.find("zyltgb") < 0:
redis_info.delete(k)
+
+
+def __clear_big_data():
+ redis_l2 = redis_manager.RedisManager(1).getRedis()
+ keys = redis_l2.keys("big_data-*")
+ for k in keys:
+ redis_l2.delete(k)
if __name__ == "__main__":
# time_str = datetime.datetime.now().strftime("%Y-%m-%d %H:%M:%S")
# print(time_str)
- __clear_data("000593")
+ # __clear_data("002093")
+ __clear_big_data()
+ pass
--
Gitblit v1.8.0