| | |
|---|
| | | import xmdapi |
|---|
| | | from huaxin_api import tool |
|---|
| | | from huaxin_api.client_network import SendResponseSkManager |
|---|
| | | from log_module.log import logger_system |
|---|
| | | from log_module.log import logger_system, logger_local_huaxin_l1 |
|---|
| | | |
|---|
| | | level1_data_dict = { |
|---|
| | | |
|---|
| | |
|---|
| | | |
|---|
| | | def run(pipe_l2): |
|---|
| | | time.sleep(10) |
|---|
| | | logger_local_huaxin_l1.info("运行l1订阅服务") |
|---|
| | | codes_sh = [] |
|---|
| | | codes_sz = [] |
|---|
| | | for i in range(3): |
|---|
| | | try: |
|---|
| | | codes_sh, codes_sz = get_level1_codes() |
|---|
| | | except: |
|---|
| | | logger_local_huaxin_l1.info(f"获取上证，深证代码数量：sh-{len(codes_sh)} sz-{len(codes_sz)}") |
|---|
| | | except Exception as e: |
|---|
| | | logger_local_huaxin_l1.exception(e) |
|---|
| | | time.sleep(4) |
|---|
| | | |
|---|
| | | # 打印接口版本号 |
|---|
