低吸数据采集

Administrator

2025-06-09 8b7972581d0324e3f634b5b5a57a9ed7db1addaf

 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: