redis批量提交数据

Administrator

2023-08-07 e0ca7b43c17ebe25e718d5ca229c989f48340015

 main.py

@@ -4,6 +4,7 @@

import multiprocessing

from db import redis_manager
from log_module.log import logger_l2_process_time

from server import *
@@ -25,6 +26,10 @@
    t1 = threading.Thread(target=trade_api_server.run, args=(pipe,), daemon=True)
    t1.start()

    # redis后台服务
    t1 = threading.Thread(target=redis_manager.RedisUtils.run_loop,  daemon=True)
    t1.start()

    # 交易服务
    trade_server.run()