| | |
|---|
| | | # 只在盘中时间获取 |
|---|
| | | now_time = tool.get_now_time_str() |
|---|
| | | if data_cache.L1_DATA_START_TIME < now_time < data_cache.CLOSING_TIME: |
|---|
| | | print("====logger_stock_of_markets_plate====") |
|---|
| | | async_log_util.info(logger_stock_of_markets_plate, f"{its_stock['list']}") |
|---|
| | | logger.info(f"its_stock['list'] ===》》 {its_stock['list']}") |
|---|
| | | # logger.info(f"its_stock['list'][0] === {its_stock['list'][0]}") |
|---|
| | |
|---|
| | | # logger.info(f"market_sift_plate['list'][0] ======{market_sift_plate['list'][0]}") |
|---|
| | | # 初始化精选板块对应个股字典 |
|---|
| | | market_sift_plate_stock_dict = {} |
|---|
| | | # if 'list' in market_sift_plate: |
|---|
| | | # ds = [] |
|---|
| | | # for d in market_sift_plate['list']: |
|---|
| | | # ds.append(request_plate_codes(d)) |
|---|
| | | # dask_result = batch_get_plate_codes(ds) |
|---|
| | | # dask_result.compute() |
|---|
| | | if 'list' in market_sift_plate: |
|---|
| | | ds = [] |
|---|
| | | for d in market_sift_plate['list']: |
|---|
| | | ds.append(request_plate_codes(d)) |
|---|
| | | dask_result = batch_get_plate_codes(ds) |
|---|
| | | dask_result.compute() |
|---|
| | | # now_time = tool.get_now_time_str() |
|---|
| | | # if data_cache.L1_DATA_START_TIME < now_time < data_cache.CLOSING_TIME: |
|---|
| | | # logger.info(f"精选板块股票强度数据更新 == {market_sift_plate_stock_dict}") |
|---|
