From d2a4dd9c837f8df2a19e58f7fb4c81a91c114b67 Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期五, 15 八月 2025 13:15:32 +0800
Subject: [PATCH] 自动加想接口
---
third_data/hx_qc_value_util.py | 4 +---
1 files changed, 1 insertions(+), 3 deletions(-)
diff --git a/third_data/hx_qc_value_util.py b/third_data/hx_qc_value_util.py
index 477141b..cfa2f3e 100644
--- a/third_data/hx_qc_value_util.py
+++ b/third_data/hx_qc_value_util.py
@@ -70,7 +70,6 @@
@param end_date:
@return:
"""
- logger_debug.info("get_history_k_bars寮�濮�")
load_latest_trade_calendar()
_count = -1
start_date = None
@@ -85,7 +84,6 @@
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)
@@ -147,7 +145,7 @@
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()
--
Gitblit v1.8.0