redis缓存加入内存缓存

Administrator

2023-08-02 f889cad52174b5bb1dc1ca6fecac7e71d59e905d

 trade/huaxin/trade_server.py

@@ -1,5 +1,6 @@
import datetime
import hashlib
import io
import json
import logging
import queue
@@ -10,7 +11,9 @@
import time

import dask
from line_profiler import LineProfiler

import constant
from code_attribute import gpcode_manager
from l2 import l2_data_manager_new, l2_log, code_price_manager, l2_data_util, l2_data_manager, transaction_progress
from l2.cancel_buy_strategy import HourCancelBigNumComputer, LCancelBigNumComputer, DCancelBigNumComputer
@@ -288,7 +291,8 @@
                                    days=100)).timestamp() > datetime.datetime.now().timestamp():
                                continue
                            fdatas.append(d["sec_id"])
                        sk.sendall(socket_util.load_header(json.dumps({"code": 0, "data":fdatas}).encode(encoding='utf-8')))
                        sk.sendall(
                            socket_util.load_header(json.dumps({"code": 0, "data": fdatas}).encode(encoding='utf-8')))

                    elif data_json["type"] == "set_target_codes":
                        try:
@@ -296,6 +300,20 @@
                            datas = data["data"]
                            print("set_target_codes", data_json)
                            HuaXinL1TargetCodesManager.set_level_1_codes_datas(datas)

                            lp = LineProfiler()
                            lp.enable()
                            lp_wrap = lp(HuaXinL1TargetCodesManager.set_level_1_codes_datas)
                            lp_wrap(datas)
                            output = io.StringIO()
                            lp.print_stats(stream=output)
                            lp.disable()
                            with open(
                                    f"{constant.get_path_prefix()}/logs/profile/set_level_1_codes_datas_{time.time()}.txt",
                                    'w') as f:
                                f.write(output.getvalue())


                        except Exception as e:
                            logging.exception(e)
                        finally: