| | |
|---|
| | | |
|---|
| | | |
|---|
| | | def get_yesterday_limit_up_codes(): |
|---|
| | | yesterday_limit_up_data_records = get_current_limit_up_data_records(1)[0][1] |
|---|
| | | yesterday_limit_up_data_records = get_yesterday_current_limit_up_records() |
|---|
| | | yesterday_codes = set([x[0] for x in yesterday_limit_up_data_records]) |
|---|
| | | return yesterday_codes |
|---|
| | | |
|---|
| | | |
|---|
| | | def get_yesterday_current_limit_up_records(): |
|---|
| | | yesterday_limit_up_data_records = get_current_limit_up_data_records(1)[0][1] |
|---|
| | | return yesterday_limit_up_data_records |
|---|
| | | |
|---|
| | | |
|---|
| | | # 运行拉取任务 |
|---|
| | |
|---|
| | | results = kpl_api.getLimitUpInfo() |
|---|
| | | result = json.loads(results) |
|---|
| | | start_time = time.time() |
|---|
| | | if start_time - last_time >= 60: |
|---|
| | | last_time = start_time |
|---|
| | | # 记录涨停数据 |
|---|
| | | async_log_util.info(logger_kpl_limit_up, result) |
|---|
| | | __upload_data("limit_up", result) |
|---|
| | | if start_time - last_time >= 60: |
|---|
| | | last_time = time.time() |
|---|
| | | # 记录涨停数据 |
|---|
| | | logger_kpl_limit_up.info(result) |
|---|
| | | # logger_kpl_limit_up_reason_change.info("上传耗时：{}", time.time() - start_time) |
|---|
| | | except Exception as e: |
|---|
| | | logging.exception(e) |
|---|
