| | |
|---|
| | | ds.append(request_plate_codes(d)) |
|---|
| | | dask_result = batch_get_plate_codes(ds) |
|---|
| | | dask_result.compute() |
|---|
| | | logger.info(f"精选板块股票强度数据更新 == {market_sift_plate_stock_dict}") |
|---|
| | | now_time = datetime.datetime.now().strftime('%Y-%m-%d %H:%M:%S') |
|---|
| | | if data_cache.L1_data_start_time < now_time < data_cache.closing_time: |
|---|
| | | logger.info(f"精选板块股票强度数据更新 == {market_sift_plate_stock_dict}") |
|---|
| | | return market_sift_plate_stock_dict |
|---|
| | | |
|---|
| | | |
|---|
| | |
|---|
| | | low_emotion_mood_ratio = 0 |
|---|
| | | logger.info(f"极端低迷情绪比例===={low_emotion_mood_ratio * 100}%") |
|---|
| | | |
|---|
| | | index_trend_expectation_score = index_trend_expectation() |
|---|
| | | logger.info(f"大盘指数情绪预期分数==={index_trend_expectation_score}分") |
|---|
| | | print(f"大盘指数情绪预期分数==={index_trend_expectation_score}分") |
|---|
| | | data_cache.index_trend_expectation_score = index_trend_expectation() |
|---|
| | | logger.info(f"大盘指数情绪预期分数==={data_cache.index_trend_expectation_score}分") |
|---|
| | | # print(f"大盘指数情绪预期分数==={data_cache.index_trend_expectation_score}分") |
|---|
| | | # 目前大盘指数情绪预期分数 尚不科学 强制设置为初始0值 |
|---|
| | | index_trend_expectation_score = 0 |
|---|
| | | |
|---|
