修改L2数据传输方式

Administrator

2023-08-29 485d37401b9b8d87b03a103b53f8a6c1c6c5f901

修改L2数据传输方式

 huaxin_client/l2_data_manager.py

@@ -286,12 +286,13 @@
    t.start()


def __test(pipe_strage):
def __test(pipe_strategy):
    code = "002073"
    if code not in tmep_order_detail_queue_dict:
        tmep_order_detail_queue_dict[code] = queue.Queue()
    target_codes.add(code)
    run_upload_task(code, pipe_strage)
    t = threading.Thread(target=lambda: __run_upload_order(code, pipe_strategy), daemon=True)
    t.start()
    while True:
        try:
            tmep_order_detail_queue_dict[code].put_nowait(

 log_module/log.py

@@ -363,10 +363,10 @@

def close_print():
    pass
    logging.basicConfig(level=logging.ERROR)
    if not constant.is_windows():
        os.close(1)
        os.open('/dev/null', os.O_WRONLY)
    # logging.basicConfig(level=logging.ERROR)
    # if not constant.is_windows():
    #     os.close(1)
    #     os.open('/dev/null', os.O_WRONLY)


if __name__ == "__main__":