| | |
|---|
| | | import time |
|---|
| | | |
|---|
| | | from log_module.log import logger_common |
|---|
| | | from strategy import data_cache |
|---|
| | | from strategy import data_cache, market_sentiment_analysis |
|---|
| | | from strategy import kpl_api |
|---|
| | | from utils import tool |
|---|
| | | |
|---|
| | |
|---|
| | | logger.info(f"获取所有个股的板块概念 已经运行完成") |
|---|
| | | # 完成了后将是否执行的开个标记为真 |
|---|
| | | data_cache.execution = True |
|---|
| | | # 本地数据更新时间 |
|---|
| | | if data_cache.UPDATE_DATA_TIME < now_time and data_cache.index_K_line_write_execution is False: |
|---|
| | | # 写入所有指数K线 |
|---|
| | | market_sentiment_analysis.all_index_k_line_dict_write() |
|---|
| | | logger.info(f"写入所有带属性指数K线 已经运行完成") |
|---|
| | | # 完成了后将是否执行的开个标记为真 |
|---|
| | | data_cache.index_K_line_write_execution = True |
|---|
| | | except Exception as error: |
|---|
| | | logger.error(f"实时检测定时器线程报错: {error}") |
|---|
| | | finally: |
|---|
