redis缓存加入内存缓存

Administrator

2023-08-02 f889cad52174b5bb1dc1ca6fecac7e71d59e905d

redis缓存加入内存缓存

 l2/huaxin/huaxin_target_codes_manager.py

@@ -99,18 +99,7 @@
            flist.append(fitem)
        print("首板代码数量", len(flist))
        try:
            # 分析时间
            lp = LineProfiler()
            lp.enable()
            lp_wrap = lp(first_target_code_data_processor.process_first_codes_datas)
            tick_datas = lp_wrap(flist)
            output = io.StringIO()
            lp.print_stats(stream=output)
            lp.disable()
            with open(f"{constant.get_path_prefix()}/logs/profile/first_target_code_data_processor_{int(time.time())}.txt", 'w') as f:
                f.write(output.getvalue())

            # tick_datas = first_target_code_data_processor.process_first_codes_datas(flist)
            tick_datas = first_target_code_data_processor.process_first_codes_datas(flist)
            current_price_process_manager.accept_prices(tick_datas)
        except Exception as e:
            logging.exception(e)

 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: