From 8b7972581d0324e3f634b5b5a57a9ed7db1addaf Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期一, 09 六月 2025 18:58:15 +0800
Subject: [PATCH] 低吸数据采集
---
l2_test.py | 14 ++++++++++++--
1 files changed, 12 insertions(+), 2 deletions(-)
diff --git a/l2_test.py b/l2_test.py
index e11794f..a951c0c 100644
--- a/l2_test.py
+++ b/l2_test.py
@@ -11,6 +11,7 @@
import psutil
import requests
+from api import low_suction_data_pusher
from code_attribute import global_data_loader
from huaxin_client import l2_client_test, l1_subscript_codes_manager
from log_module.log import logger_local_huaxin_l2_transaction_big_order, logger_system, \
@@ -143,8 +144,13 @@
def __save_accurate_big_order(big_accurate_order_queue):
while True:
try:
- data = big_accurate_order_queue.get()
- logger_local_huaxin_l2_transaction_accurate_big_order.info(f"{data}")
+ datas = []
+ while not big_accurate_order_queue.empty():
+ data = big_accurate_order_queue.get()
+ datas.append(data)
+ low_suction_data_pusher.push_big_order(datas)
+ for data in datas:
+ logger_local_huaxin_l2_transaction_accurate_big_order.info(f"{data}")
except:
pass
@@ -222,6 +228,10 @@
__upload_data("jingxuan_rank", json.dumps(fins))
__upload_data("jingxuan_rank_out", json.dumps(fouts))
__upload_codes_in_money()
+ try:
+ low_suction_data_pusher.push_block_in(in_list)
+ except:
+ pass
except Exception as e:
logging.exception(e)
finally:
--
Gitblit v1.8.0