From 56147d4716f2e001a8605bcc39b80cad3b27e217 Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期五, 29 三月 2024 14:50:52 +0800
Subject: [PATCH] 持仓L2订阅
---
huaxin_client/l2_client.py | 3 +++
1 files changed, 3 insertions(+), 0 deletions(-)
diff --git a/huaxin_client/l2_client.py b/huaxin_client/l2_client.py
index 513e29b..28e20c3 100644
--- a/huaxin_client/l2_client.py
+++ b/huaxin_client/l2_client.py
@@ -310,6 +310,7 @@
data = json.loads(value)
_type = data["type"]
if _type == "l2_cmd":
+ huaxin_l2_log.info(logger_local_huaxin_l2_subscript, f"璁㈤槄浠ｇ爜锛歿data}")
__start_time = time.time()
# 绾跨▼姹�
__l2_cmd_thread_pool.submit(
@@ -381,6 +382,8 @@
data_callback_distribute_manager = CodeDataCallbackDistributeManager(data_callbacks)
l2_data_upload_manager = L2DataUploadManager(data_callback_distribute_manager)
__init_l2(l2_data_upload_manager)
+
+ threading.Thread(target=huaxin_l2_log.run_sync, daemon=True).start()
# TODO 娴嬭瘯
# threading.Thread(target=lambda: test_add_codes(queue_r), daemon=True).start()
global l2CommandManager
--
Gitblit v1.8.0