添加必要的数据日志

admin

3 天以前 0b0d0e790fec8c7edfdbcab5c31d625e0c2eadd6

 strategy/data_cache.py

@@ -11,7 +11,8 @@
import constant
# 引入掘金API
import utils.juejin_api
from log_module.log import logger_common
from log_module import async_log_util
from log_module.log import logger_common, logger_target_codes
# from logging_config import get_logger
from utils import tool, hx_qc_value_util

@@ -65,7 +66,7 @@
        # 获取A股市场（包含沪深两市）的股票列表跳过停牌，跳过ST    上交所 SHSE.600000   深交所 SZSE.000000    target = ['SHSE.603839', 'SZSE.002855']
        self.all_stocks = utils.juejin_api.JueJinApi.get_target_codes()
        # self.all_stocks = [{'sec_level': 1, 'symbol': 'SZSE.301633','pre_close': 78.72000122070312, 'is_suspended': 0, 'sec_name': '港迪技术', 'listed_date': datetime.datetime(2024, 11, 7, 0, 0,tzinfo=datetime.timezone(datetime.timedelta(seconds=28800))), 'sec_type': 1, 'sec_id': '301633'}]

        async_log_util.info(logger_target_codes, f"{ self.all_stocks}")
        # self.all_stocks = self.all_stocks[:10]
        # 缓存代码的名称
        self.code_name_dict = {x['symbol']: x['sec_name'] for x in self.all_stocks}
@@ -76,8 +77,8 @@
        #                         stock.startswith('SHSE.60') or (stock.startswith('SZSE.00'))]
        self.filtered_stocks = [stock['symbol'] for stock in self.all_stocks if
                                isinstance(stock.get('symbol'), str) and (
                                            stock['symbol'].startswith('SHSE.60') or stock['symbol'].startswith(
                                        'SZSE.00'))]
                                        stock['symbol'].startswith('SHSE.60') or stock['symbol'].startswith(
                                    'SZSE.00'))]
        # self.filtered_stocks =  self.filtered_stocks[:10]
        print(f"过滤后上证A股和深证A股数量filtered_stocks：{len(self.filtered_stocks)}")
        # 声明一下需要拉取K线的列表
@@ -156,6 +157,9 @@
limit_up_block_names = []
# 初始化板块强度下的个股强度
market_sift_plate_stock_dict = {}
# 精选流入板块
market_sift_plates = []

# 初始化实时大盘行情市场情绪综合强度【完整】字典
rise_and_fall_statistics_dirt = {}
# 初始化实时大盘行情情绪综合强度[分数]
@@ -273,7 +277,12 @@
# 最新成交价格
latest_deal_price_dict = {}

logging.info(f"全局初始化数据  完成《《《 - {os.getpid()}")

# 大单成交数据: {"代码":[大单数据1,大单数据2,...]}
big_order_deal_dict = {}

# 有意购买的股票名称列表
willing_buy_list = []
# 已成交股票详情列表
purchased_stocks_details_list = []

logging.info(f"全局初始化数据  完成《《《 - {os.getpid()}")