| | |
|---|
| | | @param end_date: |
|---|
| | | @return: |
|---|
| | | """ |
|---|
| | | logger_debug.info("get_history_k_bars开始") |
|---|
| | | load_latest_trade_calendar() |
|---|
| | | _count = -1 |
|---|
| | | start_date = None |
|---|
| | |
|---|
| | | start_date = __trade_calendar_list[i] |
|---|
| | | if _count >= count: |
|---|
| | | break |
|---|
| | | logger_debug.info(f"get_history_k_bars 获取到开始日期：{start_date}") |
|---|
| | | request_id = __base_request("get_history_k_bars", {"start_date": start_date, "end_date": end_date, "code": code}) |
|---|
| | | return __read_response(request_id) |
|---|
| | | |
|---|
| | |
|---|
| | | |
|---|
| | | 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() |
|---|
