From 091c8c8eccb8d78390cd8f2b962ade31016fdd5b Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期四, 05 十二月 2024 18:52:56 +0800
Subject: [PATCH] L2净流入订阅修改/买流入前几修改/创业板大单数量要求修改/将市场强度纳入策略
---
third_data/kpl_data_manager.py | 24 ++++++++++++++++++++++++
1 files changed, 24 insertions(+), 0 deletions(-)
diff --git a/third_data/kpl_data_manager.py b/third_data/kpl_data_manager.py
index 149b542..50e40b8 100644
--- a/third_data/kpl_data_manager.py
+++ b/third_data/kpl_data_manager.py
@@ -499,6 +499,12 @@
# # 澶т簬20s灏遍渶瑕佹洿鏂�
# threading.Thread(target=cls.run_market_jingxuan_out, daemon=True).start()
+ key = "market_strong"
+ if key not in cls.__latest_update_time_dict or time.time() - cls.__latest_update_time_dict[key] > 20:
+ logger_debug.info("浠诲姟淇-寮�鐩樺暒锛氬競鍦哄己搴�")
+ # 澶т簬20s灏遍渶瑕佹洿鏂�
+ threading.Thread(target=cls.run_market_strong, daemon=True).start()
+
@classmethod
def run_limit_up_task(cls):
# 鍏抽棴log
@@ -559,6 +565,23 @@
time.sleep(3)
@classmethod
+ def run_market_strong(cls):
+ """
+ 绮鹃�夋祦鍑�
+ @return:
+ """
+ while True:
+ try:
+ if tool.is_trade_time() or True:
+ strong_value = kpl_api.getMarketStrong()
+ cls.__upload_data("market_strong", strong_value)
+ except:
+ pass
+ finally:
+ cls.__latest_update_time_dict["market_strong"] = time.time()
+ time.sleep(3)
+
+ @classmethod
# 杩愯鎷夊彇浠诲姟
def run_pull_task(cls):
def get_bidding_money():
@@ -600,6 +623,7 @@
time.sleep(3)
threading.Thread(target=cls.run_limit_up_task, daemon=True).start()
+ threading.Thread(target=cls.run_market_strong, daemon=True).start()
# threading.Thread(target=get_bidding_money, daemon=True).start()
# threading.Thread(target=get_market_industry, daemon=True).start()
# threading.Thread(target=cls.run_market_jingxuan_in, daemon=True).start()
--
Gitblit v1.8.0