From 70b51a2636858fb8cfbf39d3764d88d07286d8ad Mon Sep 17 00:00:00 2001
From: admin <admin@example.com>
Date: 星期二, 08 四月 2025 11:27:42 +0800
Subject: [PATCH] 增加并行数量
---
strategy/check_timer.py | 9 ++++++---
1 files changed, 6 insertions(+), 3 deletions(-)
diff --git a/strategy/check_timer.py b/strategy/check_timer.py
index 2468fe3..6f41902 100644
--- a/strategy/check_timer.py
+++ b/strategy/check_timer.py
@@ -5,7 +5,7 @@
import time
from log_module.log import logger_common
-from strategy import data_cache, index_market_trend_strategy
+from strategy import data_cache, market_sentiment_analysis
from strategy import kpl_api
from utils import tool
@@ -37,9 +37,12 @@
# 瀹屾垚浜嗗悗灏嗘槸鍚︽墽琛岀殑寮�涓爣璁颁负鐪�
data_cache.execution = True
# 鏈湴鏁版嵁鏇存柊鏃堕棿
- if data_cache.UPDATE_DATA_TIME < now_time:
+ if data_cache.UPDATE_DATA_TIME < now_time and data_cache.index_K_line_write_execution is False:
# 鍐欏叆鎵�鏈夋寚鏁癒绾�
- index_market_trend_strategy.all_index_k_line_dict_write()
+ market_sentiment_analysis.all_index_k_line_dict_write()
+ logger.info(f"鍐欏叆鎵�鏈夊甫灞炴�ф寚鏁癒绾� 宸茬粡杩愯瀹屾垚")
+ # 瀹屾垚浜嗗悗灏嗘槸鍚︽墽琛岀殑寮�涓爣璁颁负鐪�
+ data_cache.index_K_line_write_execution = True
except Exception as error:
logger.error(f"瀹炴椂妫�娴嬪畾鏃跺櫒绾跨▼鎶ラ敊: {error}")
finally:
--
Gitblit v1.8.0