线程日志

Administrator

2023-09-12 f51020827076bbd5fd53470039042b7f2d4b5237

线程日志

 db/redis_manager_delegate.py

@@ -196,7 +196,7 @@
    @classmethod
    def run_loop(cls):
        logger_system.info("启动Redis数据同步服务")
        logger_system.debug(f"线程ID，redis：{threading.get_ident()}")
        logger_system.debug(f"线程ID，redis：{threading.current_thread().ident}")
        dataList = []
        last_upload_time = time.time()
        while True:

 huaxin_client/l2_client.py

@@ -574,7 +574,7 @@


def run(pipe_trade, _pipe_strategy, _l2_data_callback: l2_data_transform_protocol.L2DataCallBack)->None:
    logger_system.debug(f"线程ID，l2_client：{threading.get_ident()}")
    logger_system.debug(f"线程ID，l2_client：{threading.current_thread().ident}")
    logger_system.info("L2进程ID：{}", os.getpid())
    try:
        log.close_print()

 huaxin_client/trade_client.py

@@ -1113,7 +1113,7 @@

def run(trade_response_: TradeResponse, pipe_l2=None, pipe_strategy=None):
    try:
        logger_system.debug(f"线程ID，trade_client：{threading.get_ident()}")
        logger_system.debug(f"线程ID，trade_client：{threading.current_thread().ident}")
        logger_system.info("交易进程ID：{}", os.getpid())
        __init_trade_data_server()
        global l2pipe

 main.py

@@ -69,7 +69,7 @@


def createDataServer():
    logger_system.debug(f"线程ID，dataServer：{threading.get_ident()}")
    logger_system.debug(f"线程ID，dataServer：{threading.current_thread().ident}")
    logger_system.info("create DataServer")
    tcpserver = data_server.run("", 9004)
    tcpserver.serve_forever()

 trade/huaxin/trade_api_server.py

@@ -500,7 +500,7 @@


def run(pipe_server, pipe_l2):
    logger_system.debug(f"线程ID，trade_api_server：{threading.get_ident()}")
    logger_system.debug(f"线程ID，trade_api_server：{threading.current_thread().ident}")
    logger_system.info("create TradeApiServer")
    # 拉取交易信息
    huaxin_trade_data_update.run()

 trade/huaxin/trade_server.py

@@ -821,7 +821,7 @@

def run(pipe_trade, pipe_l1, pipe_l2, trade_cmd_callback):
    try:
        logger_system.debug(f"线程ID，trade_server：{threading.get_ident()}")
        logger_system.debug(f"线程ID，trade_server：{threading.current_thread().ident}")
        # 执行一些初始化数据
        block_info.init()