| | |
|---|
| | | import time |
|---|
| | | |
|---|
| | | from huaxin_client import l1_api_client |
|---|
| | | from log_module.log import logger_debug |
|---|
| | | from utils import tool |
|---|
| | | |
|---|
| | | __response_data = {} |
|---|
| | |
|---|
| | | |
|---|
| | | def run(): |
|---|
| | | global request_queue |
|---|
| | | request_queue, response_queue = multiprocessing.Queue(), multiprocessing.Queue() |
|---|
| | | request_queue, response_queue = multiprocessing.Queue(maxsize=1024), multiprocessing.Queue(maxsize=1024) |
|---|
| | | # 启动增值服务进程 |
|---|
| | | process = multiprocessing.Process(target=l1_api_client.run, args=(request_queue, response_queue,), daemon=True) |
|---|
| | | process.start() |
|---|
| | |
|---|
| | | |
|---|
| | | def __test(): |
|---|
| | | time.sleep(5) |
|---|
| | | print( get_history_k_bars("000333", count=150)) |
|---|
| | | print(get_history_k_bars("000333", count=150)) |
|---|
| | | print(get_previous_trading_date("2024-12-31")) |
|---|
| | | print(get_next_trading_date("2024-12-30")) |
|---|
| | | |
|---|
